Home
last modified time | relevance | path

Searched defs:UnboundedSender (Results 1 – 5 of 5) sorted by relevance

/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/mpsc/
Dunbounded.rs11 pub struct UnboundedSender<T> { struct
17 /// If all [`UnboundedSender`] instances of a channel were dropped and only argument
49 impl<T> Clone for UnboundedSender<T> { implementation
57 impl<T> fmt::Debug for UnboundedSender<T> { implementation
523 impl<T> UnboundedSender<T> { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/client/
Ddispatch.rs49 pub(crate) struct UnboundedSender<T, U> { struct
52 inner: mpsc::UnboundedSender<Envelope<T, U>>, argument
115 impl<T, U> UnboundedSender<T, U> { implementation
143 impl<T, U> Clone for UnboundedSender<T, U> { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/futures-channel/src/mpsc/
Dmod.rs128 pub struct UnboundedSender<T>(Option<UnboundedSenderInner<T>>); struct
132 impl AssertKinds for UnboundedSender<u32> {} implementation
766 impl<T> UnboundedSender<T> { implementation
867 impl<T> Clone for UnboundedSender<T> { implementation
961 impl<T> fmt::Debug for UnboundedSender<T> { implementation
Dsink_impl.rs33 impl<T> Sink<T> for UnboundedSender<T> { implementation
54 impl<T> Sink<T> for &UnboundedSender<T> { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/
Dsync_mpsc.rs33 impl<T> AssertRefUnwindSafe for mpsc::UnboundedSender<T> {} implementation
45 impl<T> AssertUnwindSafe for mpsc::UnboundedSender<T> {} implementation