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,