Function handle_events

Source
async fn handle_events<N, P, V>(
    consensus: Arc<RwLock<Consensus<N, P, V>>>,
    node_id: u64,
    events: impl Stream<Item = Event<SeqTypes>> + Unpin,
    persistence: Arc<P>,
    state_signer: Arc<RwLock<StateSigner<SequencerApiVersion>>>,
    external_event_handler: ExternalEventHandler<V>,
    events_streamer: Option<Arc<RwLock<EventsStreamer<SeqTypes>>>>,
    event_consumer: impl PersistenceEventConsumer + 'static,
    anchor_view: Option<ViewNumber>,
)