pub async fn register(&self, event_types: Vec<EventType>) -> InvocationReceiver {
        let (tx, rx) = mpsc::channel(0);
        let sender = InvocationSender::new(tx);
        let receiver = InvocationReceiver::new(rx);

        let mut sender_map = self.sender_map.lock().await;
        for event_type in event_types {
            let senders = sender_map.entry(event_type).or_insert(vec![]);
            senders.push(sender.clone());
        }

        receiver
    }
/// Registers breakpoints against a set of EventTypes.
Registers breakpoints against a set of EventTypes.
Registers breakpoints against a set of EventTypes .
pub async fn register(&self, event_types: Vec<EventType>) -> InvocationReceiver {
        let (tx, rx) = mpsc::channel(0);
        let sender = InvocationSender::new(tx);
        let receiver = InvocationReceiver::new(rx);
        let mut sender_map = self.sender_map.lock().await;
        for event_type in event_types {
            let senders = sender_map.entry(event_type).or_insert(vec![]);
            senders.push(sender.clone());
        }
        receiver
    }
pub async fn register ( & self , event_types : Vec < EventType > ) -> InvocationReceiver { let ( tx , rx ) = mpsc :: channel ( 0 ) ; let sender = InvocationSender :: new ( tx ) ; let receiver = InvocationReceiver :: new ( rx ) ; let mut sender_map = self . sender_map . lock ( ) . await ; for event_type in event_types { let senders = sender_map . entry ( event_type ) . or_insert ( vec ! [ ] ) ; senders . push ( sender . clone ( ) ) ; } receiver }
Registers breakpoints against a set of EventTypes.
Registers breakpoints against a set of EventTypes .
&self
event_types
Vec<EventType>