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.