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.