fn poll_next_procedure_update(
        &mut self,
        cx: &mut Context<'_>,
    ) -> Poll<Option<<Self as Stream>::Item>> {
        match self.receiver.poll_next_unpin(cx) {
            Poll::Ready(Some(request)) => Poll::Ready(Some(Ok(request))),
            Poll::Ready(None) => {
                info!("Internal procedure update channel closed unexpectedly");
                Poll::Ready(None)
            }
            Poll::Pending => Poll::Pending,
        }
    }
/// Helper function to poll the internal channel for information requests from any procedures.
Helper function to poll the internal channel for information requests from any procedures.
Helper function to poll the internal channel for information requests from any procedures .
fn poll_next_procedure_update(
        &mut self,
        cx: &mut Context<'_>,
    ) -> Poll<Option<<Self as Stream>::Item>> {
        match self.receiver.poll_next_unpin(cx) {
            Poll::Ready(Some(request)) => Poll::Ready(Some(Ok(request))),
            Poll::Ready(None) => {
                info!("Internal procedure update channel closed unexpectedly");
                Poll::Ready(None)
            }
            Poll::Pending => Poll::Pending,
        }
    }
fn poll_next_procedure_update ( & mut self , cx : & mut Context < ' _ > , ) -> Poll < Option < < Self as Stream > :: Item > > { match self . receiver . poll_next_unpin ( cx ) { Poll :: Ready ( Some ( request ) ) => Poll :: Ready ( Some ( Ok ( request ) ) ) , Poll :: Ready ( None ) => { info ! ( " " ) ; Poll :: Ready ( None ) } Poll :: Pending => Poll :: Pending , } }
Helper function to poll the internal channel for information requests from any procedures.
Helper function to poll the internal channel for information requests from any procedures .
&mut self
cx
&mut Context<'_>
&mut self
cx
&mut Context<'_>