| /external/rust/android-crates-io/crates/futures-core/src/ |
| D | stream.rs | 76 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>; in poll_next() method
113 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
129 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
218 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
231 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> { in poll_next() method
|
| /external/rust/android-crates-io/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 | peekable.rs | 42 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| D | timeout_repeating.rs | 33 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| D | chain.rs | 35 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T::Item>> { in poll_next() function
|
| /external/rust/android-crates-io/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/android-crates-io/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/android-crates-io/crates/futures-util/src/stream/try_stream/ |
| D | try_flatten_unordered.rs | 89 fn poll_next(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
133 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| 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/android-crates-io/crates/tokio/tests/ |
| D | time_interval.rs | 355 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next() function
382 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/android-crates-io/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
|
| /external/rust/android-crates-io/crates/tower/tests/ |
| D | support.rs | 37 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
45 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/android-crates-io/crates/tower/src/discover/ |
| D | list.rs | 46 fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| /external/rust/android-crates-io/crates/futures-util/src/io/ |
| D | lines.rs | 35 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
|
| /external/rust/android-crates-io/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/android-crates-io/crates/tokio-stream/src/ |
| D | stream_close.rs | 64 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| 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/android-crates-io/crates/futures-util/src/stream/ |
| D | poll_immediate.rs | 24 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| /external/rust/android-crates-io/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 | 33 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
|
| /external/rust/android-crates-io/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
|