Trait janus::Subscriber

pub trait Subscriber: Stream<Item = Result<AckMessage<Self::Message>, Self::Error>> + Unpin {
    type Message;
    type Error: Error + Send + Sync + 'static;
}

Produces a stream of Messages.

Associated Types

type Message

The type of Message that the subscriber will produce when successful.

type Error: Error + Send + Sync + 'static

The type of Error that the subscriber will produce when it fails.

Loading content...

Implementors

Loading content...