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>>,
)where
P: SequencerPersistence,
C: PersistenceEventConsumer + 'static,