Searched refs:UnboundedSender (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | unbounded.rs | 12 pub struct UnboundedSender<T> { struct
16 impl<T> Clone for UnboundedSender<T> { implementation
18 UnboundedSender { in clone()
24 impl<T> fmt::Debug for UnboundedSender<T> { implementation
63 pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>) { in unbounded_channel()
66 let tx = UnboundedSender::new(tx); in unbounded_channel()
183 impl<T> UnboundedSender<T> { implementation
184 pub(crate) fn new(chan: chan::Tx<T, Semaphore>) -> UnboundedSender<T> { in new()
185 UnboundedSender { chan } in new()
|
| D | mod.rs | 83 pub use self::unbounded::{unbounded_channel, UnboundedReceiver, UnboundedSender};
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | sink_impl.rs | 1 use super::{SendError, Sender, TrySendError, UnboundedSender};
45 impl<T> Sink<T> for UnboundedSender<T> { implementation
78 impl<T> Sink<T> for &UnboundedSender<T> { implementation
85 UnboundedSender::poll_ready(*self, cx) in poll_ready()
|
| D | mod.rs | 132 pub struct UnboundedSender<T>(Option<UnboundedSenderInner<T>>); struct
135 impl AssertKinds for UnboundedSender<u32> {} implementation
401 pub fn unbounded<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>) { in unbounded()
418 (UnboundedSender(Some(tx)), rx) in unbounded()
810 impl<T> UnboundedSender<T> { impl
905 impl<T> Clone for UnboundedSender<T> { implementation
|
| /external/rust/crates/futures-channel/benches/ |
| D | sync_mpsc.rs | 8 channel::mpsc::{self, Sender, UnboundedSender},
32 UnboundedSender::unbounded_send(&tx, i).unwrap(); in unbounded_1_tx()
54 UnboundedSender::unbounded_send(x, i).unwrap(); in unbounded_100_tx()
69 UnboundedSender::unbounded_send(&tx, i).expect("send"); in unbounded_uncontended()
|
| /external/rust/crates/tokio-stream/tests/support/ |
| D | mpsc.rs | 2 use tokio::sync::mpsc::{self, UnboundedSender};
5 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream()
|
| /external/rust/crates/tokio/tests/support/ |
| D | mpsc_stream.rs | 5 use tokio::sync::mpsc::{self, Receiver, Sender, UnboundedReceiver, UnboundedSender};
18 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream()
|
| /external/rust/crates/tokio-test/src/ |
| D | io.rs | 47 tx: mpsc::UnboundedSender<Action>,
|