async fn send(&self, event: Event) -> Result<oneshot::Receiver<()>, Error> {
        trace::duration!("component_manager", "breakpoints:send");
        let event_type = format!("{:?}", event.payload.type_());
        let target_moniker = event.target_moniker.to_string();
        trace::flow_begin!(
            "component_manager",
            "event",
            event.id,
            "event_type" => event_type.as_str(),
            "target_moniker" => target_moniker.as_str()
        );
        let (responder_tx, responder_rx) = oneshot::channel();
        {
            let mut tx = self.tx.lock().await;
            tx.send(Invocation { event, responder: responder_tx }).await?;
        }
        Ok(responder_rx)
    }
/// Sends the event to a receiver. Returns a responder which can be blocked on.
Sends the event to a receiver. Returns a responder which can be blocked on.
Sends the event to a receiver . Returns a responder which can be blocked on .
async fn send(&self, event: Event) -> Result<oneshot::Receiver<()>, Error> {
        trace::duration!("component_manager", "breakpoints:send");
        let event_type = format!("{:?}", event.payload.type_());
        let target_moniker = event.target_moniker.to_string();
        trace::flow_begin!(
            "component_manager",
            "event",
            event.id,
            "event_type" => event_type.as_str(),
            "target_moniker" => target_moniker.as_str()
        );
        let (responder_tx, responder_rx) = oneshot::channel();
        {
            let mut tx = self.tx.lock().await;
            tx.send(Invocation { event, responder: responder_tx }).await?;
        }
        Ok(responder_rx)
    }
async fn send ( & self , event : Event ) -> Result < oneshot :: Receiver < ( ) > , Error > { trace :: duration ! ( " " " " ) ; let event_type = format ! ( " " event payload type_ ( ) ) ; let target_moniker = event . target_moniker . to_string ( ) ; trace :: flow_begin ! ( " " " " event id " " event_type as_str ( ) " " target_moniker as_str ( ) ) ; let ( responder_tx , responder_rx ) = oneshot :: channel ( ) ; { let mut tx = self . tx . lock ( ) . await ; tx . send ( Invocation { event , responder : responder_tx } ) . await ? ; } Ok ( responder_rx ) }
Sends the event to a receiver.
Sends the event to a receiver .
&self
event
Event