Trait jsonrpc_utils::pubsub::PubSub

pub trait PubSub {
    type Stream: Stream<Item = PublishMsg> + Send;

    fn subscribe(&self, params: Params) -> Result<Self::Stream, Error>;
}

Implement this trait to define actual pub/sub logic.

Streams

Stream wrappers from tokio-stream can be used, e.g. BroadcastStream.

Or use the async-stream crate to implement streams with async-await. See the example server.

Required Associated Types

type Stream: Stream<Item = PublishMsg> + Send

Required Methods

fn subscribe(&self, params: Params) -> Result<Self::Stream, Error>

Implementations on Foreign Types

impl<T: PubSub> PubSub for Arc<T>

type Stream = <T as PubSub>::Stream

fn subscribe(&self, params: Params) -> Result<Self::Stream, Error>

Implementors

impl<F: Fn(Params) -> Result<S, Error>, S: Stream<Item = PublishMsg> + Send> PubSub for F

type Stream = S