Mountain/Vine/Client/SubscribeNotifications.rs
1
2//! Subscribe to the global notification fan-out. Each call returns a
3//! fresh receiver that observes every notification fanned out AFTER
4//! subscribe time (broadcast semantics; no historical replay). Drop the
5//! receiver to unsubscribe.
6
7use crate::Vine::Client::{NotificationFrame, Shared};
8
9pub fn Fn() -> tokio::sync::broadcast::Receiver<NotificationFrame::Struct> {
10 Shared::NOTIFICATION_BROADCAST.subscribe()
11}