Trait mz_persist_client::rpc::PubSubReceiver

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

The receive-side client to Persist PubSub.

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

Implementors§

source§

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