Searched defs:StreamMsg (Results 1 – 2 of 2) sorted by relevance
35 pub enum StreamMsg { enum378 pub fn msg_sender(&self) -> &Sender<Box<StreamMsg>> { in msg_sender()383 pub fn send_msg(sender: &Sender<Box<StreamMsg>>, msg: StreamMsg) -> Result<()> { in send_msg()
540 senders: Vec<Sender<Box<StreamMsg>>>, in io_loop()