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>,
)