Struct Streamer 

pub struct Streamer { /* private fields */ }

Implementations

impl Streamer

pub fn new() -> Arc<Self>

pub fn connected_clients(&self) -> usize

pub fn new_client(&self, s: TcpStream)

pub fn send(&self, data: &str)

pub fn send_json_with_event<T: Serialize>(&self, event: &str, data: &T)

pub fn send_with_event(&self, event: &str, data: &str)

pub fn send_json<T: Serialize>(&self, data: &T)

pub fn start<F: FnOnce(&str) -> bool + Send + 'static + Clone>( self: Arc<Self>, addr: &str, control_fn: F, ) -> Result<()>