Home
last modified time | relevance | path

Searched refs:TransmitterEvent (Results 1 – 2 of 2) sorted by relevance

/xiu/library/streamhub/src/
H A Dlib.rs45 event_receiver: UnboundedReceiver<TransmitterEvent>, in new() argument
172 TransmitterEvent::Subscribe { sender, info } => { in receive_event_loop()
193 TransmitterEvent::UnSubscribe { info } => match info.sub_type { in receive_event_loop()
201 TransmitterEvent::UnPublish {} => { in receive_event_loop()
207 TransmitterEvent::Api { sender } => { in receive_event_loop()
216 TransmitterEvent::Request { sender } => { in receive_event_loop()
523 let event = TransmitterEvent::Request { sender }; in request()
540 if let Err(err) = v.send(TransmitterEvent::Api { in api_statistic()
600 let event = TransmitterEvent::Subscribe { in subscribe()
640 let event = TransmitterEvent::UnSubscribe { info: sub_info }; in unsubscribe()
[all …]
H A Ddefine.rs161 pub type TransmitterEventSender = mpsc::UnboundedSender<TransmitterEvent>;
162 pub type TransmitterEventReceiver = mpsc::UnboundedReceiver<TransmitterEvent>;
251 pub enum TransmitterEvent { enum
269 impl fmt::Display for TransmitterEvent { implementation