| /external/rust/crates/futures-sink/src/ |
| D | lib.rs | 89 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>; in start_send() method
126 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
150 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
175 fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
197 fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
222 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 13 fn start_send(mut self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> { in start_send() method
40 fn start_send(mut self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> { in start_send() method
61 fn start_send(self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/tokio-util/src/io/ |
| D | copy_to_bytes.rs | 55 fn start_send(self: Pin<&mut Self>, item: &'a [u8]) -> Result<(), Self::Error> { in start_send() function
|
| /external/rust/crates/futures-util/src/sink/ |
| D | drain.rs | 48 fn start_send(self: Pin<&mut Self>, _item: T) -> Result<(), Self::Error> { in start_send() method
|
| D | map_err.rs | 41 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
|
| D | unfold.rs | 58 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
|
| D | buffer.rs | 85 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
|
| D | with_flat_map.rs | 110 fn start_send(self: Pin<&mut Self>, item: U) -> Result<(), Self::Error> { in start_send() function
|
| D | with.rs | 115 fn start_send(self: Pin<&mut Self>, item: U) -> Result<(), Self::Error> { in start_send() function
|
| D | fanout.rs | 78 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 65 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/futures/tests/ |
| D | stream_split.rs | 33 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in test_split() method
|
| D | future_try_flatten_stream.rs | 60 fn start_send(self: Pin<&mut Self>, _: Item) -> Result<(), Self::Error> { in assert_impls() method
|
| D | auto_traits.rs | 59 fn start_send(self: Pin<&mut Self>, _: T) -> Result<(), Self::Error> { in start_send() method
|
| D | sink.rs | 109 fn start_send(mut self: Pin<&mut Self>, item: Option<T>) -> Result<(), Self::Error> { in start_send() method
189 fn start_send(mut self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/futures-util/src/future/try_future/ |
| D | try_flatten.rs | 136 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
|
| /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
|
| /external/rust/crates/futures-test/src/ |
| D | track_closed.rs | 122 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/tokio-util/src/codec/ |
| D | framed_write.rs | 151 fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), Self::Error> { in start_send() function
|
| D | framed_read.rs | 172 fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), Self::Error> { in start_send() function
|
| D | framed_impl.rs | 270 fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), Self::Error> { in start_send() function
|
| D | framed.rs | 318 fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), Self::Error> { in start_send() function
|
| /external/rust/crates/tokio-util/src/sync/ |
| D | mpsc.rs | 276 fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
|
| /external/rust/crates/tokio-util/src/udp/ |
| D | frame.rs | 126 fn start_send(self: Pin<&mut Self>, item: (I, SocketAddr)) -> Result<(), Self::Error> { in start_send() function
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 99 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), S::Error> { in start_send() method
|