Home
last modified time | relevance | path

Searched refs:poll_shutdown (Results 1 – 25 of 28) sorted by relevance

12

/external/rust/crates/tokio/src/io/
Dasync_write.rs129 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>>; in poll_shutdown() method
207 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
208 Pin::new(&mut **self).poll_shutdown(cx)
250 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() function
251 self.get_mut().as_mut().poll_shutdown(cx) in poll_shutdown()
281 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
311 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
341 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
371 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
401 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
Dstdio_common.rs100 fn poll_shutdown( in poll_shutdown() function
104 Pin::new(&mut self.inner).poll_shutdown(cx) in poll_shutdown()
136 fn poll_shutdown( in poll_shutdown() method
171 fn poll_shutdown( in poll_shutdown() method
Dstderr.rs103 fn poll_shutdown( in poll_shutdown() method
107 Pin::new(&mut self.std).poll_shutdown(cx) in poll_shutdown()
Dstdout.rs102 fn poll_shutdown( in poll_shutdown() method
106 Pin::new(&mut self.std).poll_shutdown(cx) in poll_shutdown()
Dsplit.rs126 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_shutdown() method
128 inner.stream_pin().poll_shutdown(cx) in poll_shutdown()
Dblocking.rs173 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_shutdown() function
/external/rust/crates/tokio/src/io/util/
Dmem.rs126 fn poll_shutdown( in poll_shutdown() method
130 Pin::new(&mut *self.write.lock()).poll_shutdown(cx) in poll_shutdown()
216 fn poll_shutdown( in poll_shutdown() method
Dbuf_stream.rs130 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
131 self.project().inner.poll_shutdown(cx) in poll_shutdown()
Dbuf_writer.rs139 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
141 self.get_pin_mut().poll_shutdown(cx) in poll_shutdown()
Dbuf_reader.rs157 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
158 self.get_pin_mut().poll_shutdown(cx) in poll_shutdown()
Dshutdown.rs44 Pin::new(me.a).poll_shutdown(cx) in poll()
Dsink.rs68 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_shutdown() method
Dcopy_bidirectional.rs43 ready!(w.as_mut().poll_shutdown(cx))?; in transfer_one_direction()
/external/rust/crates/tokio/tests/
Dio_write_int.rs27 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in write_int_should_err_if_write_count_0() method
Dio_write_all.rs38 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in write_all() method
Dio_write_buf.rs40 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in write_all() method
Dio_write.rs34 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in write() method
Dio_split.rs36 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_shutdown() method
/external/rust/crates/tokio/src/net/unix/
Dsplit.rs85 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
Dsplit_owned.rs172 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
Dstream.rs680 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
/external/rust/crates/tokio/src/net/tcp/
Dsplit.rs177 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
Dsplit_owned.rs259 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
Dstream.rs1092 fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method
/external/rust/crates/tokio-test/src/
Dio.rs448 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut task::Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown() method

12