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