| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 111 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_close() method
129 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() method
130 Pin::new(&mut **self).poll_close(cx) in poll_close()
153 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() function
154 self.get_mut().as_mut().poll_close(cx) in poll_close()
180 fn poll_close(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() method
202 fn poll_close(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() method
222 … fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() method
223 Pin::new(&mut **self).poll_close(cx) in poll_close()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 36 fn poll_close( in poll_close() method
69 fn poll_close( in poll_close() method
100 fn poll_close( in poll_close() method
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 225 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>; in poll_close() method
411 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
412 Pin::new(&mut **self).poll_close(cx)
446 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_close() function
447 self.get_mut().as_mut().poll_close(cx) in poll_close()
469 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 155 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() function
157 Either::Left(x) => x.poll_close(cx), in poll_close()
158 Either::Right(x) => x.poll_close(cx), in poll_close()
246 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_close() function
248 Either::Left(x) => x.poll_close(cx), in poll_close()
249 Either::Right(x) => x.poll_close(cx), in poll_close()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | fanout.rs | 102 fn poll_close( in poll_close() function
108 let sink1_ready = this.sink1.poll_close(cx)?.is_ready(); in poll_close()
109 let sink2_ready = this.sink2.poll_close(cx)?.is_ready(); in poll_close()
|
| D | map_err.rs | 57 fn poll_close( in poll_close() function
61 self.as_mut().project().sink.poll_close(cx).map_err(|e| self.as_mut().take_f()(e)) in poll_close()
|
| D | buffer.rs | 112 fn poll_close( in poll_close() method
118 self.project().sink.poll_close(cx) in poll_close()
|
| D | with.rs | 145 fn poll_close( in poll_close() function
150 ready!(self.project().sink.poll_close(cx)?); in poll_close()
|
| D | with_flat_map.rs | 141 fn poll_close( in poll_close() function
146 self.project().sink.poll_close(cx) in poll_close()
|
| D | close.rs | 36 Pin::new(&mut self.sink).poll_close(cx) in poll()
|
| D | drain.rs | 59 fn poll_close( in poll_close() method
|
| D | unfold.rs | 86 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_close() function
|
| /external/rust/crates/futures/tests/ |
| D | split.rs | 53 fn poll_close( in test_split() method
57 self.project().sink.poll_close(cx) in test_split()
|
| D | io_buf_writer.rs | 37 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_close() method
38 Pin::new(&mut self.inner).poll_close(cx) in poll_close()
238 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in maybe_pending_buf_writer_seek() method
239 Pin::new(&mut self.inner).poll_close(cx) in maybe_pending_buf_writer_seek()
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 92 fn poll_close( in poll_close() method
98 ready!(self.project().writer.poll_close(cx))?; in poll_close()
|
| D | buf_writer.rs | 129 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_close() method
131 self.project().inner.poll_close(cx) in poll_close()
|
| D | split.rs | 88 fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_close() method
89 lock_and_then(&self.handle, cx, |l, cx| l.poll_close(cx)) in poll_close()
|
| D | close.rs | 26 Pin::new(&mut *self.writer).poll_close(cx) in poll()
|
| D | sink.rs | 58 fn poll_close(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_close() method
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | flatten.rs | 143 fn poll_close( in poll_close() function
148 FlattenProj::Second { f } => f.poll_close(cx), in poll_close()
|
| /external/rust/crates/futures-util/src/ |
| D | lib.rs | 87 fn poll_close(
91 self.project().$field.poll_close(cx)
145 fn poll_close(
149 self.project().$field.poll_close(cx)
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | into_async_read.rs | 125 fn poll_close( in poll_close() function
129 Pin::new( &mut self.stream ).poll_close( cx ) in poll_close()
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 158 fn poll_close( in poll_close() function
163 TryFlattenProj::Second { f } => f.poll_close(cx), in poll_close()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 108 fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), S::Error>> { in poll_close() method
112 inner.as_pin_mut().poll_close(cx) in poll_close()
|
| D | forward.rs | 71 ready!(si.poll_close(cx))?; in poll()
|