Home
last modified time | relevance | path

Searched defs:start_send (Results 1 – 25 of 26) sorted by relevance

12

/external/rust/crates/futures-sink/src/
Dlib.rs84 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
145 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
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
/external/rust/crates/futures-channel/src/mpsc/
Dsink_impl.rs16 fn start_send( in start_send() method
55 fn start_send( in start_send() method
88 fn start_send(self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> { in start_send() method
Dmod.rs741 pub fn start_send(&mut self, msg: T) -> Result<(), SendError> { in start_send() method
860 pub fn start_send(&mut self, msg: T) -> Result<(), SendError> { in start_send() method
/external/rust/crates/futures-util/src/sink/
Ddrain.rs45 fn start_send( in start_send() method
Dunfold.rs61 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
Dmap_err.rs43 fn start_send( in start_send() function
Dbuffer.rs89 fn start_send( in start_send() method
Dwith_flat_map.rs122 fn start_send( in start_send() function
Dwith.rs125 fn start_send( in start_send() function
Dfanout.rs79 fn start_send( in start_send() function
/external/rust/crates/futures-util/src/io/
Dinto_sink.rs72 fn start_send( in start_send() method
/external/rust/crates/futures/tests/
Dsplit.rs39 fn start_send( in test_split() method
Dfuture_try_flatten_stream.rs69 fn start_send(self: Pin<&mut Self>, _: Item) -> Result<(), Self::Error> { in assert_impls() method
Dauto_traits.rs59 fn start_send(self: Pin<&mut Self>, _: T) -> Result<(), Self::Error> { in start_send() method
Dsink.rs123 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
/external/rust/crates/futures-util/src/future/try_future/
Dtry_flatten.rs142 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
/external/rust/crates/futures-util/src/future/future/
Dflatten.rs127 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
/external/rust/crates/futures-util/src/stream/stream/
Dsplit.rs96 fn start_send(mut self: Pin<&mut Self>, item: Item) -> Result<(), S::Error> { in start_send() method
/external/rust/crates/futures-util/src/future/
Deither.rs141 fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error> { in start_send() function
/external/rust/crates/futures-util/src/compat/
Dcompat03as01.rs150 fn start_send( in start_send() function
Dcompat01as03.rs259 fn start_send( in start_send() function
/external/rust/crates/crossbeam-channel/src/flavors/
Dzero.rs115 fn start_send(&self, token: &mut Token) -> bool { in start_send() method
Darray.rs156 fn start_send(&self, token: &mut Token) -> bool { in start_send() method
Dlist.rs196 fn start_send(&self, token: &mut Token) -> bool { in start_send() method
/external/rust/crates/grpcio/src/call/
Dclient.rs373 fn start_send(mut self: Pin<&mut Self>, (msg, flags): (Req, WriteFlags)) -> Result<()> { in start_send() method

12