Struct HmrBroadcaster 

pub struct HmrBroadcaster { /* private fields */ }

Fan-out HMR sender shared across the dev server.

Construct one per ssg dev process. Each connected tab registers an HmrSink via Self::subscribe; Self::broadcast pushes the same frame to every live tab and evicts any sink that errored.

Implementations

impl HmrBroadcaster

pub fn new() -> Self

Construct an empty broadcaster.

Examples

use ssg::hmr::HmrBroadcaster;
let b = HmrBroadcaster::new();
assert_eq!(b.subscriber_count(), 0);

pub fn subscribe(&self, sink: HmrSink)

Register a new tab. The sink is invoked on every subsequent Self::broadcast until it returns Err(()).

Examples

use ssg::hmr::HmrBroadcaster;
let b = HmrBroadcaster::new();
b.subscribe(Box::new(|_| Ok(())));
assert_eq!(b.subscriber_count(), 1);

pub fn subscriber_count(&self) -> usize

Returns the current number of subscribed tabs. Useful for tests and the dev-server status banner.

Examples

use ssg::hmr::HmrBroadcaster;
let b = HmrBroadcaster::new();
assert_eq!(b.subscriber_count(), 0);

pub fn broadcast(&self, msg: &HmrMessage) -> usize

Push msg to every subscriber. Sinks that return Err(()) are evicted in-place.

Returns the number of tabs that successfully received the frame.

Examples

use ssg::hmr::{HmrBroadcaster, HmrMessage};
let b = HmrBroadcaster::new();
b.subscribe(Box::new(|_| Ok(())));
assert_eq!(b.broadcast(&HmrMessage::reload()), 1);

Trait Implementations

impl Debug for HmrBroadcaster

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for HmrBroadcaster

fn default() -> HmrBroadcaster

Returns the “default value” for a type.