Struct FeedHub 

pub struct FeedHub {
    subs: RwLock<HashMap<(String, String), Vec<Subscriber>>>,
    next_id: AtomicU64,
    max_behind: usize,
}

Every open feed’s subscription, by the block and file it follows.

Fields

subs: RwLock<HashMap<(String, String), Vec<Subscriber>>>

next_id: AtomicU64

max_behind: usize

Implementations

impl FeedHub

pub fn with_max_behind(max_behind: usize) -> Self

pub fn install(self: &Arc<Self>, broker: &Broker)

Watch broker for transcript events. Called once per broker.

pub fn subscribe(self: &Arc<Self>, block_id: &str) -> FeedSubscription

Start receiving block_id’s transcript changes. Subscribe before reading the snapshot, so nothing published in between is missed; the feed drops what the snapshot already holds by line number.

pub fn subscribe_file( self: &Arc<Self>, block_id: &str, filename: &str, ) -> FeedSubscription

Start receiving the changes of block_id’s filename (the transcript, or TERM_FILE).

fn unsubscribe(&self, key: &(String, String), id: u64)

pub fn observe(&self, event: &MuxEvent)

The broker observer. Runs on every publish, so it returns at once for anything but an event of a followed block’s followed file, and never blocks.

Trait Implementations

impl Default for FeedHub

fn default() -> Self

Returns the “default value” for a type.