/// Helper function to poll the new_calls hanging get for any available items.
/// Polls until there are no more items ready. Updates internal state with the
/// available items.
Helper function to poll the new_calls hanging get for any available items.
Polls until there are no more items ready. Updates internal state with the
available items.
Helper function to poll the new_calls hanging get for any available items . Polls until there are no more items ready . Updates internal state with the available items .
fn poll_and_consume_new_calls(&mut self, cx: &mut Context<'_>) {
        // Loop until pending or self.new_calls is set to None.
        while let Some(new_calls) = &mut self.new_calls {
            match new_calls.poll_next_unpin(cx) {
                Poll::Ready(Some(Ok((call, fidl_number, state)))) => {
                    self.handle_new_call(call, fidl_number.into(), state);
                }
                Poll::Ready(Some(Err(_e))) => self.new_calls = None,
                Poll::Ready(None) => self.new_calls = None,
                Poll::Pending => break,
            }
        }
    }
fn poll_and_consume_new_calls ( & mut self , cx : & mut Context < ' _ > ) { // Loop until pending or self.new_calls is set to None. while let Some ( new_calls ) = & mut self . new_calls { match new_calls . poll_next_unpin ( cx ) { Poll :: Ready ( Some ( Ok ( ( call , fidl_number , state ) ) ) ) => { self . handle_new_call ( call , fidl_number . into ( ) , state ) ; } Poll :: Ready ( Some ( Err ( _e ) ) ) => self . new_calls = None , Poll :: Ready ( None ) => self . new_calls = None , Poll :: Pending => break , } } }
Helper function to poll the new_calls hanging get for any available items.
Helper function to poll the new_calls hanging get for any available items .
&mut self
cx
&mut Context<'_>