Searched refs:Sender (Results 1 - 9 of 9) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/ |
| H A D | registry.rs | 17 use crate::sync::watch::{channel, Receiver, Sender};
22 inner: Sender<()>,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | oneshot.rs | 15 //! single receiver. The [`channel`] function returns a [`Sender`] and
18 //! The `Sender` handle is used by the producer to send a message.
38 //! Err(_) => println!("Sender dropped"),
57 /// Sender has sent the value.
62 /// Creates a new one-shot channel with a `Sender` and `Receiver` handle pair.
64 /// The `Sender` can send a single value to the `Receiver`.
80 /// Err(_) => println!("Sender dropped"),
84 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel()
86 let tx = Sender { in channel()
94 /// A [`Sender`] an
136 pub struct Sender<T> { global() structure names
140 impl<T> Sender<T> { global() impls
[all...] |
| H A D | watch.rs | 33 /// Creates a new watch channel with a `Sender` and `Receiver` handle pair.
35 /// The value sent by the `Sender` can be seen by all receivers, but only the
36 /// last value sent by `Sender` is visible to the `Receiver`.
52 pub fn channel<T>(value: T) -> (Sender<T>, Receiver<T>) { in channel()
54 let tx = Sender { in channel()
65 /// A [`Sender`] and [`Receiver`] handle pair is created by the [`channel`]
84 pub struct Sender<T> { structure names
88 impl<T> Sender<T> { impls
170 impl<T> Drop for Sender<T> {
256 /// A [`Sender`] an
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 26 use crate::sync::watch::{channel, Receiver, Sender};
29 inner: Sender<()>,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http2.rs | 25 use tokio::sync::mpsc::{Receiver, Sender};
37 pub client_shutdown: Sender<()>,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 77 Receiver as BoundedReceiver, Sender as BoundedSender, UnboundedReceiver,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 26 use tokio::sync::mpsc::{Receiver, Sender};
35 pub client_shutdown: Sender<()>,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 362 pub async fn ylong_tcp_server(tx: crate::sync::oneshot::Sender<SocketAddr>) {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 474 async fn udp_receiver(tx: crate::sync::oneshot::Sender<SocketAddr>) { in ut_sleep_drop()
|
Completed in 5 milliseconds