Struct http_stream::stream::Streamer

pub struct Streamer { /* fields omitted */ }

Methods

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(self: Arc<Self>, addr: &str) -> Result<()>