| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 84 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>; in start_send() method
121 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
122 Pin::new(&mut **self).start_send(item) in start_send()
145 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
146 self.get_mut().as_mut().start_send(item) in start_send()
170 fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
192 fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
214 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
215 Pin::new(&mut **self).start_send(item) in start_send()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 16 fn start_send( in start_send() method
20 (*self).start_send(msg) in start_send()
55 fn start_send( in start_send() method
59 Self::start_send(&mut *self, msg) in start_send()
88 fn start_send(self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/futures/tests/ |
| D | sink.rs | 96 Pin::new(&mut inner).start_send(item.take().unwrap())?; in poll()
123 fn start_send(mut self: Pin<&mut Self>, item: Option<T>) -> Result<(), Self::Error> { in start_send() method
217 fn start_send(mut self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
253 Pin::new(&mut s).start_send(0).unwrap(); in either_sink()
263 Pin::new(&mut v).start_send(0).unwrap(); in vec_sink()
264 Pin::new(&mut v).start_send(1).unwrap(); in vec_sink()
277 Pin::new(&mut deque).start_send(2).unwrap(); in vecdeque_sink()
278 Pin::new(&mut deque).start_send(3).unwrap(); in vecdeque_sink()
336 tx.start_send(0).unwrap(); in mpsc_blocking_start_send()
375 assert_eq!(Pin::new(&mut sink).start_send(0).ok(), Some(())); in with_flush()
[all …]
|
| D | split.rs | 39 fn start_send( in test_split() method
43 self.project().sink.start_send(item) in test_split()
|
| D | future_try_flatten_stream.rs | 69 fn start_send(self: Pin<&mut Self>, _: Item) -> Result<(), Self::Error> { in assert_impls() method
|
| /external/rust/crates/futures-util/src/sink/ |
| D | fanout.rs | 79 fn start_send( in start_send() function
85 this.sink1.start_send(item.clone())?; in start_send()
86 this.sink2.start_send(item)?; in start_send()
|
| D | buffer.rs | 41 this.sink.as_mut().start_send(item)?; in try_empty_buffer()
89 fn start_send( in start_send() method
94 self.project().sink.start_send(item) in start_send()
|
| D | map_err.rs | 43 fn start_send( in start_send() function
47 self.as_mut().project().sink.start_send(item).map_err(|e| self.as_mut().take_f()(e)) in start_send()
|
| D | with_flat_map.rs | 66 this.sink.as_mut().start_send(item)?; in try_empty_stream()
71 Poll::Ready(()) => this.sink.as_mut().start_send(item)?, in try_empty_stream()
122 fn start_send( in start_send() function
|
| D | with.rs | 103 this.sink.start_send(item)?; in poll()
125 fn start_send( in start_send() function
|
| D | drain.rs | 45 fn start_send( in start_send() method
|
| D | feed.rs | 46 sink.as_mut().start_send(item)?; in poll()
|
| D | unfold.rs | 61 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
|
| D | send_all.rs | 69 Poll::Ready(Pin::new(&mut self.sink).start_send(item)) in try_start_send()
|
| /external/rust/crates/futures-util/src/compat/ |
| D | compat01as03.rs | 259 fn start_send( in start_send() function
273 Some(item) => match self.in_notify(cx, |f| f.start_send(item))? { in poll_ready()
290 Some(i) => match f.start_send(i)? { in poll_flush()
316 if let AsyncSink01::NotReady(item) = f.start_send(item)? { in poll_close()
|
| D | compat03as01.rs | 150 fn start_send( in start_send() function
157 inner.start_send(item).map(|()| AsyncSink01::Ready) in start_send()
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | flatten.rs | 127 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
130 FlattenProj::Second { f } => f.start_send(item), in start_send()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | array.rs | 156 fn start_send(&self, token: &mut Token) -> bool { in start_send() method
337 if self.start_send(token) { in try_send()
351 if self.start_send(token) { in send()
609 self.0.start_send(token) in try_select()
|
| D | list.rs | 196 fn start_send(&self, token: &mut Token) -> bool { in start_send() method
418 assert!(self.start_send(token)); in send()
643 self.0.start_send(token) in try_select()
|
| /external/rust/crates/futures-util/src/future/ |
| D | either.rs | 141 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
143 Either::Left(x) => x.start_send(item), in start_send()
144 Either::Right(x) => x.start_send(item), in start_send()
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 142 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
145 TryFlattenProj::Second { f } => f.start_send(item), in start_send()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 71 Poll::Ready(inner.start_send(slot.take().unwrap())) in poll_flush_slot()
96 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), S::Error> { in start_send() method
|
| D | forward.rs | 63 si.as_mut().start_send(buffered_item.take().unwrap())?; in poll()
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 72 fn start_send( in start_send() method
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc.rs | 38 assert!(tx.as_mut().start_send(1).is_ok()); in send_recv_no_buffer()
43 assert!(tx.as_mut().start_send(0).unwrap_err().is_full()); in send_recv_no_buffer()
52 assert!(tx.as_mut().start_send(2).is_ok()); in send_recv_no_buffer()
|