| /external/rust/crates/tokio/src/io/ |
| D | async_write.rs | 69 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>>; in poll_flush() method
203 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
204 Pin::new(&mut **self).poll_flush(cx)
246 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() function
247 self.get_mut().as_mut().poll_flush(cx) in poll_flush()
277 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
307 fn poll_flush(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
312 self.poll_flush(cx) in poll_shutdown()
337 fn poll_flush(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
342 self.poll_flush(cx) in poll_shutdown()
[all …]
|
| D | stdio_common.rs | 93 fn poll_flush( in poll_flush() function
97 Pin::new(&mut self.inner).poll_flush(cx) in poll_flush()
132 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
167 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
|
| D | stderr.rs | 99 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
100 Pin::new(&mut self.std).poll_flush(cx) in poll_flush()
|
| D | stdout.rs | 98 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
99 Pin::new(&mut self.std).poll_flush(cx) in poll_flush()
|
| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 98 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_flush() method
125 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() method
126 Pin::new(&mut **self).poll_flush(cx) in poll_flush()
149 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() function
150 self.get_mut().as_mut().poll_flush(cx) in poll_flush()
176 fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() method
198 fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() method
218 … fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() method
219 Pin::new(&mut **self).poll_flush(cx) in poll_flush()
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 208 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>; in poll_flush() method
407 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
408 Pin::new(&mut **self).poll_flush(cx)
442 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_flush() function
443 self.get_mut().as_mut().poll_flush(cx) in poll_flush()
465 fn poll_flush(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<()>> {
470 self.poll_flush(cx)
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 23 fn poll_flush( in poll_flush() method
62 fn poll_flush( in poll_flush() method
93 fn poll_flush( in poll_flush() method
|
| /external/rust/crates/futures-util/src/sink/ |
| D | unfold.rs | 58 self.poll_flush(cx) in poll_ready()
71 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() function
87 self.poll_flush(cx) in poll_close()
|
| D | fanout.rs | 90 fn poll_flush( in poll_flush() function
96 let sink1_ready = this.sink1.poll_flush(cx)?.is_ready(); in poll_flush()
97 let sink2_ready = this.sink2.poll_flush(cx)?.is_ready(); in poll_flush()
|
| D | map_err.rs | 50 fn poll_flush( in poll_flush() function
54 self.as_mut().project().sink.poll_flush(cx).map_err(|e| self.as_mut().take_f()(e)) in poll_flush()
|
| D | buffer.rs | 102 fn poll_flush( in poll_flush() method
108 self.project().sink.poll_flush(cx) in poll_flush()
|
| D | send_all.rs | 103 ready!(Pin::new(&mut this.sink).poll_flush(cx))?; in poll()
107 ready!(Pin::new(&mut this.sink).poll_flush(cx))?; in poll()
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 148 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() function
150 Either::Left(x) => x.poll_flush(cx), in poll_flush()
151 Either::Right(x) => x.poll_flush(cx), in poll_flush()
239 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_flush() function
241 Either::Left(x) => x.poll_flush(cx), in poll_flush()
242 Either::Right(x) => x.poll_flush(cx), in poll_flush()
|
| /external/rust/crates/tokio/src/io/util/ |
| D | mem.rs | 118 fn poll_flush( in poll_flush() method
122 Pin::new(&mut *self.write.lock()).poll_flush(cx) in poll_flush()
212 fn poll_flush(self: Pin<&mut Self>, _: &mut task::Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush() method
|
| D | buf_stream.rs | 126 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
127 self.project().inner.poll_flush(cx) in poll_flush()
|
| D | buf_writer.rs | 134 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
136 self.get_pin_mut().poll_flush(cx) in poll_flush()
|
| D | buf_reader.rs | 153 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
154 self.get_pin_mut().poll_flush(cx) in poll_flush()
|
| /external/rust/crates/futures/tests/ |
| D | split.rs | 46 fn poll_flush( in test_split() method
50 self.project().sink.poll_flush(cx) in test_split()
|
| D | io_buf_writer.rs | 33 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
34 Pin::new(&mut self.inner).poll_flush(cx) in poll_flush()
234 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in maybe_pending_buf_writer_seek() method
235 Pin::new(&mut self.inner).poll_flush(cx) in maybe_pending_buf_writer_seek()
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 82 fn poll_flush( in poll_flush() method
88 ready!(self.project().writer.poll_flush(cx))?; in poll_flush()
|
| D | cursor.rs | 214 fn poll_flush(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> {
219 self.poll_flush(cx)
|
| D | buf_writer.rs | 124 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
126 self.project().inner.poll_flush(cx) in poll_flush()
|
| D | split.rs | 84 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush() method
85 lock_and_then(&self.handle, cx, |l, cx| l.poll_flush(cx)) in poll_flush()
|
| /external/rust/crates/tokio/src/fs/ |
| D | file.rs | 678 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
680 inner.poll_flush(cx) in poll_flush()
684 self.poll_flush(cx) in poll_shutdown()
734 if let Err(e) = poll_fn(|cx| Pin::new(&mut *self).poll_flush(cx)).await { in complete_inflight()
739 fn poll_flush(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush() method
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | flatten.rs | 135 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_flush() function
138 FlattenProj::Second { f } => f.poll_flush(cx), in poll_flush()
|