| /external/rust/android-crates-io/crates/combine/tests/support/ |
| D | mod.rs | 37 fn poll_read( in poll_read() function
45 Pin::new(&mut self.inner).poll_read(cx, &mut buf[..len]) in poll_read()
59 Some(PartialOp::Unlimited) | None => Pin::new(&mut self.inner).poll_read(cx, buf), in poll_read()
68 fn poll_read( in poll_read() function
78 ready!(Pin::new(&mut self.inner).poll_read(cx, &mut sub_buf))?; in poll_read()
95 Some(PartialOp::Unlimited) | None => Pin::new(&mut self.inner).poll_read(cx, buf), in poll_read()
104 fn poll_read( in poll_read() function
114 ready!(Pin::new(&mut self.inner).poll_read(cx, &mut sub_buf))?; in poll_read()
131 Some(PartialOp::Unlimited) | None => Pin::new(&mut self.inner).poll_read(cx, buf), in poll_read()
161 fn poll_read( in poll_read() function
[all …]
|
| /external/rust/android-crates-io/crates/tokio/src/io/ |
| D | async_read.rs | 54 fn poll_read( in poll_read() method
63 fn poll_read(
68 Pin::new(&mut **self).poll_read(cx, buf)
86 fn poll_read( in poll_read() function
91 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
96 fn poll_read( in poll_read() method
110 fn poll_read( in poll_read() method
|
| D | stdin.rs | 87 fn poll_read( in poll_read() method
92 Pin::new(&mut self.std).poll_read(cx, buf) in poll_read()
|
| D | join.rs | 77 fn poll_read( in poll_read() function
82 self.project().reader.poll_read(cx, buf) in poll_read()
|
| /external/rust/android-crates-io/crates/futures-io/src/ |
| D | lib.rs | 63 fn poll_read( in poll_read() method
98 return self.poll_read(cx, b); in poll_read_vectored()
102 self.poll_read(cx, &mut []) in poll_read_vectored()
305 fn poll_read(
310 Pin::new(&mut **self).poll_read(cx, buf)
336 fn poll_read( in poll_read() function
341 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
355 fn poll_read(
|
| /external/rust/android-crates-io/crates/tonic/src/transport/service/ |
| D | io.rs | 44 fn poll_read( in poll_read() method
49 Pin::new(&mut self.0).poll_read(cx, buf) in poll_read()
135 fn poll_read( in poll_read() function
141 Self::Io(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
143 Self::TlsIo(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
|
| /external/rust/android-crates-io/crates/tokio-util/src/io/ |
| D | inspect.rs | 41 fn poll_read( in poll_read() method
48 ready!(me.reader.poll_read(cx, buf))?; in poll_read()
172 fn poll_read( in poll_read() method
177 self.project().writer.poll_read(cx, buf) in poll_read()
|
| D | sink_writer.rs | 127 fn poll_read( in poll_read() method
132 self.project().inner.poll_read(cx, buf) in poll_read()
|
| /external/rust/android-crates-io/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 | 127 fn poll_read( in poll_read() method
132 Pin::new(&mut *self.read.lock()).poll_read(cx, buf) in poll_read()
329 fn poll_read(
346 fn poll_read(
|
| D | take.rs | 79 fn poll_read( in poll_read() method
92 ready!(me.inner.poll_read(cx, &mut b))?; in poll_read()
|
| D | buf_reader.rs | 101 fn poll_read( in poll_read() method
110 let res = ready!(self.as_mut().get_pin_mut().poll_read(cx, buf)); in poll_read()
133 ready!(me.inner.poll_read(cx, &mut buf))?; in poll_fill_buf()
|
| /external/rust/android-crates-io/crates/futures-util/src/io/ |
| D | chain.rs | 79 fn poll_read( in poll_read() function
87 match ready!(this.first.poll_read(cx, buf)?) { in poll_read()
92 this.second.poll_read(cx, buf) in poll_read()
|
| D | repeat.rs | 37 fn poll_read( in poll_read() method
56 nwritten += ready!(self.as_mut().poll_read(cx, buf))?; in poll_read_vectored()
|
| D | take.rs | 85 fn poll_read( in poll_read() method
97 let n = ready!(this.inner.poll_read(cx, &mut buf[..max]))?; in poll_read()
|
| D | buf_reader.rs | 111 fn poll_read( in poll_read() method
120 let res = ready!(self.as_mut().project().inner.poll_read(cx, buf)); in poll_read()
158 *this.cap = ready!(this.inner.poll_read(cx, this.buffer))?; in poll_fill_buf()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | io_read.rs | 24 fn poll_read( in read() method
58 fn poll_read( in poll_read() method
|
| D | io_take.rs | 36 std::future::poll_fn(|cx| rd.as_mut().poll_read(cx, &mut read_buf)) in issue_4435()
55 fn poll_read( in poll_read() method
|
| D | io_buf_reader.rs | 45 fn poll_read( in poll_read() method
52 Pin::new(&mut self.inner).poll_read(cx, buf) in poll_read()
140 fn poll_read( in test_buffered_reader_seek_underflow() method
199 fn poll_read( in test_short_reads() method
300 fn poll_read( in maybe_pending_seek() method
305 Pin::new(&mut self.inner).poll_read(cx, buf) in maybe_pending_seek()
|
| /external/rust/android-crates-io/crates/tokio-io-timeout/src/ |
| D | lib.rs | 158 fn poll_read( in poll_read() function
164 let r = this.reader.poll_read(cx, buf); in poll_read()
346 fn poll_read( in poll_read() function
351 self.project().writer.poll_read(cx, buf) in poll_read()
459 fn poll_read( in poll_read() function
464 self.project().stream.poll_read(cx, buf) in poll_read()
527 fn poll_read( in poll_read() method
|
| /external/rust/android-crates-io/crates/tokio-util/src/ |
| D | compat.rs | 111 fn poll_read( in poll_read() function
119 let n = ready!(futures_io::AsyncRead::poll_read( in poll_read()
133 fn poll_read( in poll_read() function
139 ready!(tokio::io::AsyncRead::poll_read( in poll_read()
|
| /external/rust/android-crates-io/crates/futures-test/src/io/ |
| D | limited.rs | 72 fn poll_read( in poll_read() method
79 this.io.poll_read(cx, &mut buf[..limit]) in poll_read()
|
| /external/rust/android-crates-io/crates/futures/tests/ |
| D | io_buf_reader.rs | 39 fn poll_read( in poll_read() method
44 self.project().inner.poll_read(cx, buf) in poll_read()
81 fn poll_read( in poll_read() method
88 Pin::new(&mut self.inner).poll_read(cx, buf) in poll_read()
385 fn poll_read( in maybe_pending_seek() method
390 self.project().inner.poll_read(cx, buf) in maybe_pending_seek()
|
| /external/rust/android-crates-io/crates/hyper-timeout/src/ |
| D | stream.rs | 106 fn poll_read( in poll_read() function
111 self.project().stream.poll_read(cx, buf) in poll_read()
|
| /external/rust/android-crates-io/crates/combine/src/stream/ |
| D | buf_reader.rs | 291 ready!(read.poll_read(cx, &mut buf))?; in tokio_03_read_buf()
515 let n = ready!(read.poll_read(cx, bs))?; in poll_extend_buf()
529 fn poll_read( in poll_read() method
540 let res = ready!(self.as_mut().get_pin_mut().poll_read(cx, buf)); in poll_read()
609 fn poll_read( in poll_read() method
618 let res = ready!(self.as_mut().get_pin_mut().poll_read(cx, buf)); in poll_read()
672 fn poll_read( in poll_read() method
681 let res = ready!(self.as_mut().get_pin_mut().poll_read(cx, buf)); in poll_read()
|