// Create the Call Manager side of a PeerHandler to send a call state update to the
// `OngoingHeld` state in order to tear down the active sco connection.
// Once call_manager does the work required by the test, it completes, returning items that
// should be kept alive for the remainder of the test.
Create the Call Manager side of a PeerHandler to send a call state update to the
`OngoingHeld` state in order to tear down the active sco connection.
Once call_manager does the work required by the test, it completes, returning items that
should be kept alive for the remainder of the test.
Create the Call Manager side of a PeerHandler to send a call state update to the ` OngoingHeld ` state in order to tear down the active sco connection . Once call_manager does the work required by the test it completes returning items that should be kept alive for the remainder of the test .
async fn call_manager(
            stream: PeerHandlerRequestStream,
        ) -> (impl Stream<Item = PeerHandlerWatchNextCallResponder>, CallRequestStream) {
            let mut stream = wait_for_call_stream(stream).await;
            // Send the held call response
            let responder = stream.next().await.unwrap();
            let (client_end, call_stream) = fidl::endpoints::create_request_stream().unwrap();
            let next_call = NextCall {
                call: Some(client_end),
                remote: Some("1234567".to_string()),
                state: Some(CallState::OngoingHeld),
                direction: Some(CallDirection::MobileTerminated),
                ..NextCall::EMPTY
            };
            responder.send(next_call).expect("Successfully send call information");
            (stream, call_stream)
        }
async fn call_manager ( stream : PeerHandlerRequestStream , ) -> ( impl Stream < Item = PeerHandlerWatchNextCallResponder > , CallRequestStream ) { let mut stream = wait_for_call_stream ( stream ) . await ; // Send the held call response let responder = stream . next ( ) . await . unwrap ( ) ; let ( client_end , call_stream ) = fidl :: endpoints :: create_request_stream ( ) . unwrap ( ) ; let next_call = NextCall { call : Some ( client_end ) , remote : Some ( " " . to_string ( ) ) , state : Some ( CallState :: OngoingHeld ) , direction : Some ( CallDirection :: MobileTerminated ) , .. NextCall :: EMPTY } ; responder . send ( next_call ) . expect ( " " ) ; ( stream , call_stream ) }
Create the Call Manager side of a PeerHandler to send a call state update to the
`OngoingHeld` state in order to tear down the active sco connection.
Create the Call Manager side of a PeerHandler to send a call state update to the ` OngoingHeld ` state in order to tear down the active sco connection .
stream
PeerHandlerRequestStream