Trait PubSubReceiver 

pub trait PubSubReceiver:
    Stream<Item = ProtoPubSubMessage>
    + Send
    + Unpin
    + Debug { }

The receive-side client to Persist PubSub.

Returns diffs (and maybe in the future, blobs) for any shards subscribed to by the corresponding PubSubSender.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T> PubSubReceiver for T

where T: Stream<Item = ProtoPubSubMessage> + Send + Unpin + Debug,