Searched defs:StreamMsg (Results 1 – 2 of 2) sorted by relevance
36 pub enum StreamMsg { enum358 pub fn msg_sender(&self) -> &Sender<StreamMsg> { in msg_sender()363 pub fn send_msg(sender: &Sender<StreamMsg>, msg: StreamMsg) -> Result<()> { in send_msg()
547 senders: Vec<Sender<StreamMsg>>, in io_loop()