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;
|