| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 68 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_ready() method
122 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
146 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
171 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
193 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
215 fn poll_ready( in poll_ready() method
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 9 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
36 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
57 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| /external/rust/crates/tokio-util/src/io/ |
| D | copy_to_bytes.rs | 51 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/futures-util/src/sink/ |
| D | drain.rs | 44 fn poll_ready(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| D | map_err.rs | 37 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | unfold.rs | 54 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | buffer.rs | 71 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| D | with_flat_map.rs | 106 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | with.rs | 109 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | fanout.rs | 65 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 60 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| /external/rust/crates/futures/tests/ |
| D | stream_split.rs | 29 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in test_split() method
|
| D | future_try_flatten_stream.rs | 57 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in assert_impls() method
|
| D | auto_traits.rs | 56 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| D | sink.rs | 105 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
181 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 118 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | flatten.rs | 112 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/futures-test/src/ |
| D | track_closed.rs | 117 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| /external/rust/crates/tokio/src/io/bsd/ |
| D | poll_aio.rs | 167 pub fn poll_ready<'a>(&'a self, cx: &mut Context<'_>) -> Poll<io::Result<AioEvent>> { in poll_ready() method
|
| /external/rust/crates/tokio-util/src/codec/ |
| D | framed_write.rs | 147 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | framed_read.rs | 168 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/tokio/src/runtime/io/ |
| D | registration.rs | 142 fn poll_ready( in poll_ready() method
|
| /external/rust/crates/tokio-util/src/sync/ |
| D | mpsc.rs | 268 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
|
| /external/rust/crates/tokio-util/src/udp/ |
| D | frame.rs | 115 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| /external/rust/crates/tokio/tests/ |
| D | uds_datagram.rs | 329 async fn poll_ready() -> io::Result<()> { in poll_ready() function
|