| /external/rust/crates/futures-core/src/ |
| D | stream.rs | 66 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>; in poll_next() method
103 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
119 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
208 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
221 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> { 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_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/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/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/futures/tests/ |
| D | future_try_flatten_stream.rs | 32 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in failed_future() method
50 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in assert_impls() method
|
| D | stream.rs | 80 fn poll_next(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<Option<Self::Item>> { in flatten_unordered() method
111 fn poll_next(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<Option<Self::Item>> { in flatten_unordered() method
435 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/crates/futures-util/src/io/ |
| D | lines.rs | 33 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/try_stream/ |
| D | try_buffered.rs | 50 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| D | try_buffer_unordered.rs | 49 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { 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
|
| /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
|
| /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_immediate.rs | 24 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::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
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | cycle.rs | 34 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| D | flatten.rs | 46 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| D | catch_unwind.rs | 30 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/crates/tokio-util/src/io/ |
| D | reader_stream.rs | 88 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/crates/tokio/tests/ |
| D | time_interval.rs | 205 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next() function
|