| /external/rust/crates/futures-core/src/ |
| D | stream.rs | 66 fn poll_next( in poll_next() method
106 fn poll_next( in poll_next() method
125 fn poll_next( in poll_next() function
213 fn poll_next( in poll_next() method
229 fn poll_next( in poll_next() method
|
| /external/rust/crates/tokio/tests/support/ |
| D | mpsc_stream.rs | 13 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() method
31 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() method
|
| /external/rust/crates/tokio-stream/src/stream_ext/ |
| D | merge.rs | 41 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T::Item>> { in poll_next() function
60 fn poll_next<T, U>( in poll_next() function
|
| D | fuse.rs | 33 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T::Item>> { in poll_next() function
|
| D | chain.rs | 35 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T::Item>> { in poll_next() function
|
| D | filter.rs | 42 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<St::Item>> { in poll_next() function
|
| D | filter_map.rs | 42 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() function
|
| D | map.rs | 40 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() function
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | signal_windows.rs | 31 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_next() method
73 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_next() method
|
| /external/rust/crates/tokio/tests/ |
| D | time_interval.rs | 47 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next() function
|
| /external/rust/crates/futures/tests/ |
| D | future_try_flatten_stream.rs | 34 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in failed_future() method
59 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in assert_impls() method
|
| /external/rust/crates/futures-util/src/io/ |
| D | lines.rs | 38 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_fuse.rs | 14 fn poll_next(mut self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<i32>> { in poll_next() method
|
| /external/rust/crates/futures-util/src/stream/ |
| D | iter.rs | 42 fn poll_next(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<I::Item>> { in poll_next() function
|
| D | poll_fn.rs | 54 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() function
|
| D | repeat.rs | 40 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| /external/rust/crates/tokio-stream/src/ |
| D | once.rs | 45 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() method
|
| D | iter.rs | 49 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<I::Item>> { in poll_next() function
|
| D | empty.rs | 43 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<T>> { in poll_next() method
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_buffered.rs | 50 fn poll_next( in poll_next() function
|
| D | try_buffer_unordered.rs | 47 fn poll_next( in poll_next() function
|
| D | try_flatten.rs | 56 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| D | into_stream.rs | 37 fn poll_next( in poll_next() method
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | flatten.rs | 46 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| D | cycle.rs | 37 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|