linera-io / linera-protocol

Main repository for the Linera protocol
Apache License 2.0
439 stars 126 forks source link

Replace `linera_core::notifier::Notifier` by `tokio::sync::broadcast` #2171

Open Twey opened 3 months ago

Twey commented 3 months ago

We currently have a custom broadcast notifier. We can replace it by tokio::sync::broadcast channels for our notifications (and replace our callback message handler in linera_core::client with a tokio_stream::Sink that is passed to the functions that generate notifications rather than a &mut Vec<Notification>, a much less error-prone approach).