fn start_control_stream_processing_task(peer: Arc<RwLock<RemotePeer>>) -> AbortHandle {
    let (handle, registration) = AbortHandle::new_pair();
    fasync::spawn(
        Abortable::new(
            async move {
                process_control_stream(peer).await;
            },
            registration,
        )
        .map(|_| ()),
    );
    handle
}
/// Starts a task to poll control messages from the peer. Aborted when the peer connection is
/// reset. Started when we have a connection to the remote peer and we have any type of valid SDP
/// profile from the peer.
Starts a task to poll control messages from the peer. Aborted when the peer connection is
reset. Started when we have a connection to the remote peer and we have any type of valid SDP
profile from the peer.
Starts a task to poll control messages from the peer . Aborted when the peer connection is reset . Started when we have a connection to the remote peer and we have any type of valid SDP profile from the peer .
fn start_control_stream_processing_task(peer: Arc<RwLock<RemotePeer>>) -> AbortHandle {
    let (handle, registration) = AbortHandle::new_pair();
    fasync::spawn(
        Abortable::new(
            async move {
                process_control_stream(peer).await;
            },
            registration,
        )
        .map(|_| ()),
    );
    handle
}
fn start_control_stream_processing_task ( peer : Arc < RwLock < RemotePeer > > ) -> AbortHandle { let ( handle , registration ) = AbortHandle :: new_pair ( ) ; fasync :: spawn ( Abortable :: new ( async move { process_control_stream ( peer ) . await ; } , registration , ) . map ( | _ | ( ) ) , ) ; handle }
Starts a task to poll control messages from the peer.
Starts a task to poll control messages from the peer .
peer
Arc<RwLock<RemotePeer>>
peer
Arc<RwLock<RemotePeer>>