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