Home
last modified time | relevance | path

Searched defs:UnboundedReceiver (Results 1 – 4 of 4) sorted by relevance

/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/mpsc/
Dunbounded.rs72 pub struct UnboundedReceiver<T> { struct
77 impl<T> fmt::Debug for UnboundedReceiver<T> { implementation
108 impl<T> UnboundedReceiver<T> { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/futures-channel/src/mpsc/
Dmod.rs144 pub struct UnboundedReceiver<T> { struct
148 // `Pin<&mut UnboundedReceiver<T>>` is never projected to `Pin<&mut T>` argument
149 impl<T> Unpin for UnboundedReceiver<T> {} implementation
1147 impl<T> UnboundedReceiver<T> { implementation
1219 impl<T> FusedStream for UnboundedReceiver<T> { implementation
1225 impl<T> Stream for UnboundedReceiver<T> { implementation
1257 impl<T> Drop for UnboundedReceiver<T> { implementation
1287 impl<T> fmt::Debug for UnboundedReceiver<T> { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/
Dsync_mpsc.rs32 impl<T> AssertRefUnwindSafe for mpsc::UnboundedReceiver<T> {} implementation
44 impl<T> AssertUnwindSafe for mpsc::UnboundedReceiver<T> {} implementation
/aosp_15_r20/packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/
Dmain.rs76 async fn async_main(rt: Arc<Runtime>, mut sigint: mpsc::UnboundedReceiver<()>) { in async_main()