Trait janus::Publisher

pub trait Publisher: Sink<Self::Message, Error = Self::Error> + Unpin {
    type Message;
    type Error: Error + Send + Sync + 'static;
}

Publishes Messages via a sink.

Associated Types

type Message

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

type Error: Error + Send + Sync + 'static

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

Loading content...

Implementors

Loading content...