pub async fn expect_observer_request(&mut self) -> Result<bredr::PeerObserverRequest, Error> {
        // The Future is gated by a timeout so that tests consistently terminate.
        self.observer_stream
            .select_next_some()
            .map_err(|e| format_err!("{:?}", e))
            .on_timeout(peer_observer_timeout().after_now(), move || {
                Err(format_err!("observer timed out"))
            })
            .await
    }
/// Expects a request over the PeerObserver protocol for this MockPeer.
///
/// Returns the request if successful.
Expects a request over the PeerObserver protocol for this MockPeer.
Returns the request if successful.
Expects a request over the PeerObserver protocol for this MockPeer . Returns the request if successful .
pub async fn expect_observer_request(&mut self) -> Result<bredr::PeerObserverRequest, Error> {
        // The Future is gated by a timeout so that tests consistently terminate.
        self.observer_stream
            .select_next_some()
            .map_err(|e| format_err!("{:?}", e))
            .on_timeout(peer_observer_timeout().after_now(), move || {
                Err(format_err!("observer timed out"))
            })
            .await
    }
pub async fn expect_observer_request ( & mut self ) -> Result < bredr :: PeerObserverRequest , Error > { // The Future is gated by a timeout so that tests consistently terminate. self . observer_stream . select_next_some ( ) . map_err ( | e | format_err ! ( " " e ) ) . on_timeout ( peer_observer_timeout ( ) . after_now ( ) , move | | { Err ( format_err ! ( " " ) ) } ) . await }
Expects a request over the PeerObserver protocol for this MockPeer.
Expects a request over the PeerObserver protocol for this MockPeer .
&mut self
&mut self