Skip to main content

handle_events

Function handle_events 

Source
async fn handle_events<P, C>(
    node_id: u64,
    events: impl Stream<Item = CoordinatorEvent<SeqTypes>> + Unpin,
    persistence: Arc<P>,
    signer_tx: Sender<DecidedLeaf>,
    external_event_handler: ExternalEventHandler,
    event_consumer: Arc<C>,
    decide_tx: Sender<Option<ViewNumber>>,
)