async fn wait_for_peek(
        &mut self,
        mut rows: std::pin::Pin<Box<dyn Future<Output = PeekResponse>>>,
    ) -> PeekResponse {
        loop {
            if let futures::task::Poll::Ready(rows) = futures::poll!(rows.as_mut()) {
                return rows;
            }
            self.drain_peek_response().await;
        }
    }
// Processes PeekResponse messages until rows has a response.
Processes PeekResponse messages until rows has a response.
Processes PeekResponse messages until rows has a response .
async fn wait_for_peek(
        &mut self,
        mut rows: std::pin::Pin<Box<dyn Future<Output = PeekResponse>>>,
    ) -> PeekResponse {
        loop {
            if let futures::task::Poll::Ready(rows) = futures::poll!(rows.as_mut()) {
                return rows;
            }
            self.drain_peek_response().await;
        }
    }
async fn wait_for_peek ( & mut self , mut rows : std :: pin :: Pin < Box < dyn Future < Output = PeekResponse > > > , ) -> PeekResponse { loop { if let futures :: task :: Poll :: Ready ( rows ) = futures :: poll ! ( rows as_mut ( ) ) { return rows ; } self . drain_peek_response ( ) . await ; } }
Processes PeekResponse messages until rows has a response.
Processes PeekResponse messages until rows has a response .
&mut self
rows
std::pin::Pin<Box<dyn Future<Output = PeekResponse>>>
&mut self
rows
std::pin::Pin<Box<dyn Future<Output = PeekResponse>>>