5     task::{Context, Poll},
42     ) -> Poll<Result<StreamResult>> {  in poll_produce()
48             Poll::Pending => {  in poll_produce()
50                     Poll::Ready(Ok(StreamResult::Cancelled))  in poll_produce()
52                     Poll::Pending  in poll_produce()
55             Poll::Ready(Some(item)) => {  in poll_produce()
57                 Poll::Ready(Ok(StreamResult::Completed))  in poll_produce()
59             Poll::Ready(None) => Poll::Ready(Ok(StreamResult::Dropped)),  in poll_produce()
83     ) -> Poll<Result<StreamResult>> {  in poll_consume()
90                 Poll::Ready(Ok(StreamResult::Cancelled))  in poll_consume()
92                 Poll::Pending  in poll_consume()
97             Poll::Pending => on_pending(),  in poll_consume()
98             Poll::Ready(result) => {  in poll_consume()
101                     Poll::Pending => on_pending(),  in poll_consume()
102                     Poll::Ready(result) => {  in poll_consume()
107                         Poll::Ready(Ok(StreamResult::Completed))  in poll_consume()
131     ) -> Poll<Result<Option<T>>> {  in poll_produce()
133             Poll::Pending if finish => Poll::Ready(Ok(None)),  in poll_produce()
134             Poll::Pending => Poll::Pending,  in poll_produce()
135             Poll::Ready(result) => Poll::Ready(Ok(Some(result?))),  in poll_produce()
157     ) -> Poll<Result<()>> {  in poll_consume()
161         Poll::Ready(Ok(()))  in poll_consume()