Function holochain::core::queue_consumer::spawn_queue_consumer_tasks
source · [−]pub async fn spawn_queue_consumer_tasks(
cell_id: CellId,
network: HolochainP2pDna,
space: &Space,
conductor_handle: ConductorHandle,
task_sender: Sender<ManagedTaskAdd>,
stop: Sender<()>
) -> (QueueTriggers, InitialQueueTriggers)
Expand description
Spawns several long-running tasks which are responsible for processing work which shows up on various databases.
Waits for the initial loop to complete before returning, to prevent causing a race condition by trying to run a workflow too soon after cell creation.