| /external/rust/crates/tokio/src/io/ |
| D | async_read.rs | 53 fn poll_read( in poll_read() method
62 fn poll_read(
67 Pin::new(&mut **self).poll_read(cx, buf)
85 fn poll_read( in poll_read() function
90 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
95 fn poll_read( in poll_read() method
109 fn poll_read( in poll_read() method
|
| D | stdin.rs | 66 fn poll_read( in poll_read() method
71 Pin::new(&mut self.std).poll_read(cx, buf) in poll_read()
|
| D | split.rs | 101 fn poll_read( in poll_read() method
107 inner.stream_pin().poll_read(cx, buf) in poll_read()
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 88 fn poll_read(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8]) in poll_read() method
118 return self.poll_read(cx, b); in poll_read_vectored()
122 self.poll_read(cx, &mut []) in poll_read_vectored()
323 fn poll_read(mut self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8])
326 Pin::new(&mut **self).poll_read(cx, buf)
355 fn poll_read(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8]) in poll_read() function
358 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
375 fn poll_read(mut self: Pin<&mut Self>, _: &mut Context<'_>, buf: &mut [u8])
|
| /external/rust/crates/tokio/src/io/util/ |
| D | chain.rs | 87 fn poll_read( in poll_read() function
96 ready!(me.first.poll_read(cx, buf))?; in poll_read()
103 me.second.poll_read(cx, buf) in poll_read()
|
| D | mem.rs | 98 fn poll_read( in poll_read() method
103 Pin::new(&mut *self.read.lock()).poll_read(cx, buf) in poll_read()
163 fn poll_read( in poll_read() method
|
| D | buf_reader.rs | 99 fn poll_read( in poll_read() method
108 let res = ready!(self.as_mut().get_pin_mut().poll_read(cx, buf)); in poll_read()
131 ready!(me.inner.poll_read(cx, &mut buf))?; in poll_fill_buf()
|
| D | take.rs | 78 fn poll_read( in poll_read() method
89 ready!(me.inner.poll_read(cx, &mut b))?; in poll_read()
|
| D | buf_stream.rs | 136 fn poll_read( in poll_read() method
141 self.project().inner.poll_read(cx, buf) in poll_read()
|
| D | buf_writer.rs | 146 fn poll_read( in poll_read() method
151 self.get_pin_mut().poll_read(cx, buf) in poll_read()
|
| D | read_int.rs | 59 *me.read += match me.src.as_mut().poll_read(cx, &mut buf) {
116 match me.reader.poll_read(cx, &mut buf) {
|
| D | repeat.rs | 51 fn poll_read( in poll_read() method
|
| D | empty.rs | 51 fn poll_read( in poll_read() method
|
| /external/rust/crates/futures-util/src/io/ |
| D | repeat.rs | 39 fn poll_read( in poll_read() method
58 nwritten += ready!(self.as_mut().poll_read(cx, buf))?; in poll_read_vectored()
|
| D | chain.rs | 85 fn poll_read( in poll_read() function
93 match ready!(this.first.poll_read(cx, buf)?) { in poll_read()
98 this.second.poll_read(cx, buf) in poll_read()
|
| D | buf_reader.rs | 82 fn poll_read( in poll_read() method
91 let res = ready!(self.as_mut().project().inner.poll_read(cx, buf)); in poll_read()
138 *this.cap = ready!(this.inner.poll_read(cx, this.buffer))?; in poll_fill_buf()
|
| D | take.rs | 88 fn poll_read( in poll_read() method
100 let n = ready!(this.inner.poll_read(cx, &mut buf[..max]))?; in poll_read()
|
| D | split.rs | 58 fn poll_read(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8]) in poll_read() method
61 lock_and_then(&self.handle, cx, |l, cx| l.poll_read(cx, buf)) in poll_read()
|
| D | empty.rs | 39 fn poll_read( in poll_read() method
|
| /external/rust/crates/tokio/tests/ |
| D | io_read.rs | 19 fn poll_read( in read() method
43 fn poll_read( in poll_read() method
|
| D | io_copy.rs | 15 fn poll_read( in copy() method
|
| D | io_read_buf.rs | 18 fn poll_read( in read_buf() method
|
| /external/rust/crates/futures/tests/ |
| D | io_buf_reader.rs | 51 fn poll_read(mut self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8]) in poll_read() method
56 Pin::new(&mut self.inner).poll_read(cx, buf) in poll_read()
313 fn poll_read(mut self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8]) in maybe_pending_seek() method
316 Pin::new(&mut self.inner).poll_read(cx, buf) in maybe_pending_seek()
|
| D | io_read_to_end.rs | 21 fn poll_read( in issue2310() method
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 189 fn poll_read( in poll_read() function
195 Either::Left(x) => x.poll_read(cx, buf), in poll_read()
196 Either::Right(x) => x.poll_read(cx, buf), in poll_read()
|