Lines Matching refs:__private
30 $crate::__private::assert::assert_is_unpin_stream(stream);
31 let stream = $crate::__private::Pin::new(stream);
33 let poll = $crate::__private::stream::Stream::poll_next(stream, &mut cx);
64 $crate::__private::assert::assert_is_unpin_stream(stream);
65 let stream = $crate::__private::Pin::new(stream);
67 match $crate::__private::stream::Stream::poll_next(stream, &mut cx) {
68 $crate::__private::task::Poll::Ready($crate::__private::Some(x)) => {
71 $crate::__private::task::Poll::Ready($crate::__private::None) => {
76 $crate::__private::task::Poll::Pending => {
108 $crate::__private::assert::assert_is_unpin_stream(stream);
109 let stream = $crate::__private::Pin::new(stream);
111 match $crate::__private::stream::Stream::poll_next(stream, &mut cx) {
112 $crate::__private::task::Poll::Ready($crate::__private::Some(_)) => {
115 $crate::__private::task::Poll::Ready($crate::__private::None) => {}
116 $crate::__private::task::Poll::Pending => {