Skip to main content

handle_events

Function handle_events 

Source
async fn handle_events<N, P, C>(
    consensus_handle: Arc<ConsensusHandle<SeqTypes, Node<N, P>>>,
    node_id: u64,
    events: impl Stream<Item = CoordinatorEvent<SeqTypes>> + Unpin,
    persistence: Arc<P>,
    state_signer: Arc<RwLock<StateSigner<SequencerApiVersion>>>,
    external_event_handler: ExternalEventHandler,
    events_streamer: Option<Arc<RwLock<EventsStreamer<SeqTypes>>>>,
    event_consumer: Arc<C>,
    decide_tx: Sender<Option<(ViewNumber, Option<Arc<CertificatePair<SeqTypes>>>)>>,
)
where N: ConnectedNetwork<PubKey>, P: SequencerPersistence, C: PersistenceEventConsumer + 'static,