mz_persist_client::rpc

Function subscribe_state_cache_to_pubsub

Source 
pub(crate) fn subscribe_state_cache_to_pubsub(
    cache: Arc<StateCache>,
    pubsub_receiver: Box<dyn PubSubReceiver>,
) -> JoinHandle<()>
Expand description

Spawns a Tokio task that consumes a PubSubReceiver, applying its diffs to a StateCache.