holochain 0.7.0-dev.20

Holochain, a framework for distributed applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! The queue consumer for the witnessing workflow.

use super::*;
use crate::conductor::manager::TaskManagerClient;
use crate::core::workflow::witnessing_workflow::witnessing_workflow;
use tracing::*;

/// Spawn the QueueConsumer for the witnessing workflow
#[instrument(skip_all)]
pub(crate) fn spawn_witnessing_consumer(
    space: Space,
    task_manager: TaskManagerClient,
    dna_network: DynHolochainP2pDna,
    trigger_sys: TriggerSender,
) -> TriggerSender {
    let (tx, rx) = TriggerSender::new();

    queue_consumer_dna_bound(
        "witnessing_consumer",
        space.dna_hash.clone(),
        task_manager,
        (tx.clone(), rx),
        move || witnessing_workflow(space.clone(), dna_network.clone(), trigger_sys.clone()),
    );

    tx
}