Searched refs:SinkExt (Results 1 – 13 of 13) sorted by relevance
| /external/rust/crates/futures/tests/ |
| D | sink.rs | 243 use futures::sink::{Sink, SinkExt}; in either_sink()
259 use futures::sink::{Sink, SinkExt}; in vec_sink()
288 use futures::sink::SinkExt; in send()
305 use futures::sink::SinkExt; in send_all()
360 use futures::sink::{Sink, SinkExt}; in with_flush()
396 use futures::sink::SinkExt; in with_as_map()
409 use futures::sink::SinkExt; in with_flat_map()
427 use futures::sink::{Sink, SinkExt}; in with_propagates_poll_ready()
461 use futures::sink::{Sink, SinkExt}; in with_flush_propagate()
492 use futures::{SinkExt, StreamExt}; in with_implements_clone()
[all …]
|
| D | sink_fanout.rs | 6 use futures::sink::SinkExt; in it_works()
|
| D | split.rs | 4 use futures::sink::{Sink, SinkExt}; in test_split()
|
| D | buffer_unordered.rs | 6 use futures::sink::SinkExt; in works()
|
| D | stream.rs | 139 use futures::sink::SinkExt; in ready_chunks()
|
| D | async_await_macros.rs | 91 use futures::sink::SinkExt; in select_streams()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | err_into.rs | 1 use crate::sink::{SinkExt, SinkMapErr};
22 sink: SinkExt::sink_map_err(sink, Into::into), in new()
|
| D | mod.rs | 61 impl<T: ?Sized, Item> SinkExt<Item> for T where T: Sink<Item> {}
65 pub trait SinkExt<Item>: Sink<Item> { trait
|
| /external/rust/crates/futures/src/ |
| D | lib.rs | 116 pub use futures_util::sink::SinkExt;
180 pub use crate::sink::SinkExt as _;
|
| /external/rust/crates/futures-channel/tests/ |
| D | channel.rs | 5 use futures::sink::SinkExt;
|
| D | mpsc-close.rs | 4 use futures::sink::SinkExt;
|
| D | mpsc.rs | 5 use futures::sink::{Sink, SinkExt};
|
| /external/rust/crates/futures-util/src/ |
| D | lib.rs | 323 pub use crate::sink::SinkExt;
|