pub async fn listen(
    provider: ComponentEventProviderProxy,
    node: inspect::Node,
) -> Result<ComponentEventStream, Error> {
    let (events_client_end, listener_request_stream) =
        fidl::endpoints::create_request_stream::<ComponentEventListenerMarker>()?;
    provider.set_listener(events_client_end)?;
    let (sender, receiver) = mpsc::channel(CHANNEL_CAPACITY);
    EventListenerServer::new(sender, node).spawn(listener_request_stream);
    Ok(receiver.boxed())
}
/// Subscribe to component lifecycle events.
/// |node| is the node where stats about events seen will be recorded.
Subscribe to component lifecycle events.
|node| is the node where stats about events seen will be recorded.
Subscribe to component lifecycle events . |node| is the node where stats about events seen will be recorded .
pub async fn listen(
    provider: ComponentEventProviderProxy,
    node: inspect::Node,
) -> Result<ComponentEventStream, Error> {
    let (events_client_end, listener_request_stream) =
        fidl::endpoints::create_request_stream::<ComponentEventListenerMarker>()?;
    provider.set_listener(events_client_end)?;
    let (sender, receiver) = mpsc::channel(CHANNEL_CAPACITY);
    EventListenerServer::new(sender, node).spawn(listener_request_stream);
    Ok(receiver.boxed())
}
pub async fn listen ( provider : ComponentEventProviderProxy , node : inspect :: Node , ) -> Result < ComponentEventStream , Error > { let ( events_client_end , listener_request_stream ) = fidl :: endpoints :: create_request_stream :: < ComponentEventListenerMarker > ( ) ? ; provider . set_listener ( events_client_end ) ? ; let ( sender , receiver ) = mpsc :: channel ( CHANNEL_CAPACITY ) ; EventListenerServer :: new ( sender , node ) . spawn ( listener_request_stream ) ; Ok ( receiver . boxed ( ) ) }
Subscribe to component lifecycle events.
Subscribe to component lifecycle events .
provider
ComponentEventProviderProxy
node
inspect::Node
provider
ComponentEventProviderProxy
node
inspect::Node