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.
pub(crate) fn subscribe_state_cache_to_pubsub(
cache: Arc<StateCache>,
pubsub_receiver: Box<dyn PubSubReceiver>,
) -> JoinHandle<()> ⓘSpawns a Tokio task that consumes a PubSubReceiver, applying its diffs to a StateCache.