Struct Subscriber

pub struct Subscriber<T, E = Error> { /* private fields */ }

New PUB-SUB subcriber.

Implementations

impl<T, E> Subscriber<T, E>

pub fn new(subscriber: Subscriber) -> Self

Wrap non-typed subscriber.

pub fn new_test<M: Into<String>>( method: M, ) -> (Self, Receiver<Result<SubscriptionId, Error>>, Receiver<String>)

Create new subscriber for tests.

pub fn reject(self, error: Error) -> Result<(), ()>

Reject subscription with given error.

pub fn assign_id(self, id: SubscriptionId) -> Result<Sink<T, E>, ()>

Assign id to this subscriber. This method consumes Subscriber and returns Sink if the connection is still open or error otherwise.

Trait Implementations

impl<T: Debug, E: Debug> Debug for Subscriber<T, E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.