async fn expect_observer_component_terminated(
        stream: &mut bredr::PeerObserverRequestStream,
    ) -> String {
        match stream.select_next_some().await {
            Ok(bredr::PeerObserverRequest::ComponentTerminated {
                component_url,
                responder,
                ..
            }) => {
                let _ = responder.send();
                return component_url;
            }
            x => panic!("Expected ComponentTerminated request but got: {:?}", x),
        }
    }
/// Expects a ComponentTerminated call to the observer `stream`.
/// Returns the URL of the terminated component.
/// Panics if the call doesn't happen.
Expects a ComponentTerminated call to the observer `stream`.
Returns the URL of the terminated component.
Panics if the call doesn't happen.
Expects a ComponentTerminated call to the observer ` stream ` . Returns the URL of the terminated component . Panics if the call doesn ' t happen .
async fn expect_observer_component_terminated(
        stream: &mut bredr::PeerObserverRequestStream,
    ) -> String {
        match stream.select_next_some().await {
            Ok(bredr::PeerObserverRequest::ComponentTerminated {
                component_url,
                responder,
                ..
            }) => {
                let _ = responder.send();
                return component_url;
            }
            x => panic!("Expected ComponentTerminated request but got: {:?}", x),
        }
    }
async fn expect_observer_component_terminated ( stream : & mut bredr :: PeerObserverRequestStream , ) -> String { match stream . select_next_some ( ) . await { Ok ( bredr :: PeerObserverRequest :: ComponentTerminated { component_url , responder , .. } ) => { let _ = responder . send ( ) ; return component_url ; } x => panic ! ( " " x ) , } }
Expects a ComponentTerminated call to the observer `stream`.
Expects a ComponentTerminated call to the observer ` stream ` .
stream
&mut bredr::PeerObserverRequestStream
stream
&mut bredr::PeerObserverRequestStream