| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 9 fn poll_ready( in poll_ready() method
13 (*self).poll_ready(cx) in poll_ready()
27 match (*self).poll_ready(cx) { in poll_flush()
48 fn poll_ready( in poll_ready() method
52 Self::poll_ready(&*self, cx) in poll_ready()
81 fn poll_ready( in poll_ready() method
85 UnboundedSender::poll_ready(*self, cx) in poll_ready()
|
| D | mod.rs | 647 fn poll_ready( in poll_ready() method
758 pub fn poll_ready( in poll_ready() method
765 inner.poll_ready(cx) in poll_ready()
812 pub fn poll_ready( in poll_ready() method
|
| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 63 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_ready() method
117 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
118 Pin::new(&mut **self).poll_ready(cx) in poll_ready()
141 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
142 self.get_mut().as_mut().poll_ready(cx) in poll_ready()
166 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
188 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
210 … fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
211 Pin::new(&mut **self).poll_ready(cx) in poll_ready()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | buffer.rs | 39 ready!(this.sink.as_mut().poll_ready(cx))?; in try_empty_buffer()
43 ready!(this.sink.as_mut().poll_ready(cx))?; in try_empty_buffer()
72 fn poll_ready( in poll_ready() method
77 return self.project().sink.poll_ready(cx); in poll_ready()
|
| D | fanout.rs | 67 fn poll_ready( in poll_ready() function
73 let sink1_ready = this.sink1.poll_ready(cx)?.is_ready(); in poll_ready()
74 let sink2_ready = this.sink2.poll_ready(cx)?.is_ready(); in poll_ready()
|
| D | with_flat_map.rs | 64 ready!(this.sink.as_mut().poll_ready(cx))?; in try_empty_stream()
70 match this.sink.as_mut().poll_ready(cx)? { in try_empty_stream()
115 fn poll_ready( in poll_ready() function
|
| D | map_err.rs | 36 fn poll_ready( in poll_ready() function
40 self.as_mut().project().sink.poll_ready(cx).map_err(|e| self.as_mut().take_f()(e)) in poll_ready()
|
| D | with.rs | 116 fn poll_ready( in poll_ready() function
121 ready!(self.project().sink.poll_ready(cx)?); in poll_ready()
|
| D | drain.rs | 38 fn poll_ready( in poll_ready() method
|
| D | feed.rs | 44 ready!(sink.as_mut().poll_ready(cx))?; in poll()
|
| D | unfold.rs | 57 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
|
| D | send_all.rs | 67 match Pin::new(&mut self.sink).poll_ready(cx)? { in try_start_send()
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc.rs | 35 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
39 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
44 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
48 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
51 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
53 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
57 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
114 match tx.poll_ready(cx) { in recv_close_gets_none()
464 assert!(tx.poll_ready(cx).is_pending()); in try_send_2()
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | registration.rs | 117 self.poll_ready(cx, Direction::Read) in poll_read_ready()
123 self.poll_ready(cx, Direction::Write) in poll_write_ready()
150 fn poll_ready( in poll_ready() method
174 let ev = ready!(self.poll_ready(cx, direction))?; in poll_io()
|
| /external/rust/crates/futures/tests/ |
| D | sink.rs | 95 ready!(Pin::new(&mut inner).poll_ready(cx))?; in poll()
119 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
209 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
442 assert_eq!(tx.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in with_propagates_poll_ready()
446 assert_eq!(tx.as_mut().poll_ready(cx), Poll::Pending); in with_propagates_poll_ready()
450 assert_eq!(tx.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in with_propagates_poll_ready()
470 unwrap(Pin::new(&mut sink).poll_ready(cx)); in with_flush_propagate()
472 unwrap(Pin::new(&mut sink).poll_ready(cx)); in with_flush_propagate()
670 assert_eq!(unfold.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in sink_unfold()
672 assert_eq!(unfold.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in sink_unfold()
[all …]
|
| D | split.rs | 32 fn poll_ready( in test_split() method
36 self.project().sink.poll_ready(cx) in test_split()
|
| D | future_try_flatten_stream.rs | 66 fn poll_ready(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in assert_impls() method
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | flatten.rs | 109 fn poll_ready( in poll_ready() function
120 break ready!(f.poll_ready(cx)); in poll_ready()
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 134 fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
136 Either::Left(x) => x.poll_ready(cx), in poll_ready()
137 Either::Right(x) => x.poll_ready(cx), in poll_ready()
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 119 fn poll_ready( in poll_ready() function
135 break ready!(f.poll_ready(cx)); in poll_ready()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 70 ready!(inner.as_mut().poll_ready(cx))?; in poll_flush_slot()
87 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), S::Error>> { in poll_ready() method
|
| D | forward.rs | 62 ready!(si.as_mut().poll_ready(cx))?; in poll()
|
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 368 fn poll_ready(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<()>> { in poll_ready() method
369 Pin::new(&mut self.sink_base).poll_ready(cx) in poll_ready()
396 ready!(Pin::new(&mut t.sink_base).poll_ready(cx)?); in poll_close()
|
| D | mod.rs | 690 fn poll_ready(&mut self, cx: &mut Context) -> Poll<Result<()>> { in poll_ready() method
708 ready!(self.poll_ready(cx)?); in poll_flush()
712 ready!(self.poll_ready(cx)?); in poll_flush()
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 62 fn poll_ready( in poll_ready() method
|