| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 14 //! Unbounded channel
23 use crate::sync::mpsc::{channel, Container, Rx, Tx};
30 /// The sender of unbounded channel.
50 channel: Tx<Queue<T>>,
56 channel: self.channel.clone(), in clone()
61 /// The receiver of unbounded channel.
80 channel: Rx<Queue<T>>,
83 /// Creates a new mpsc channel and returns a `Sender` and `Receiver` handle
100 let (tx, rx) = channel(queu in unbounded_channel()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 14 //! Bounded channel
23 use crate::sync::mpsc::{channel, Container, Rx, Tx};
31 /// The sender of bounded channel.
55 channel: Tx<Array<T>>,
61 channel: self.channel.clone(), in clone()
66 /// The receiver of bounded channel.
89 channel: Rx<Array<T>>,
92 /// Creates a new mpsc channel, and returns the `Sender` and `Receiver` handle
95 /// The channel i
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | oneshot.rs | 14 //! One-shot channel is used to send a single message from a single sender to a
15 //! single receiver. The [`channel`] function returns a [`Sender`] and
16 //! [`Receiver`] handle pair that controls channel.
29 //! let (tx, rx) = oneshot::channel();
62 /// Creates a new one-shot channel with a `Sender` and `Receiver` handle pair.
71 /// let (tx, rx) = oneshot::channel();
84 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel() functions
85 let channel = Arc::new(Channel::new()); in channel()
87 channel: channel in channel()
[all...] |
| H A D | watch.rs | 14 //! Watch channel
28 /// The least significant bit that marks the version of channel.
30 /// The flag marks that channel is closed.
33 /// Creates a new watch channel with a `Sender` and `Receiver` handle pair.
43 /// let (tx, mut rx) = watch::channel(1);
52 pub fn channel<T>(value: T) -> (Sender<T>, Receiver<T>) { in channel() functions
53 let channel = Arc::new(Channel::new(value)); in channel()
55 channel: channel.clone(), in channel()
58 channel, in channel()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| H A D | mod.rs | 49 pub(crate) fn channel<C: Container>(chan: C) -> (Tx<C>, Rx<C>) {
50 let channel = Arc::new(Channel::new(chan));
51 (Tx::new(channel.clone()), Rx::new(channel))
68 fn new(channel: Arc<Channel<C>>) -> Tx<C> { in new()
69 Tx { inner: channel } in new()
96 fn new(channel: Arc<Channel<C>>) -> Rx<C> { in new()
97 Rx { inner: channel } in new()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/ |
| H A D | registry.rs | 17 use crate::sync::watch::{channel, Receiver, Sender};
27 let (tx, _) = channel(()); in default()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http2.rs | 33 // This channel allows the server to notify the client when it is up and running.
36 // This channel allows the client to notify the server when it is ready to shut down.
39 // This channel allows the server to notify the client when it has shut down.
96 use tokio::sync::mpsc::channel;
98 let (start_tx, start_rx) = channel::<()>(1);
99 let (client_tx, mut client_rx) = channel::<()>(1);
100 let (server_tx, server_rx) = channel::<()>(1);
121 .expect("Start channel (Client-Half) be closed unexpectedly");
125 .expect("Client channel (Client-Half) be closed unexpectedly");
132 .expect("Server channel (Clien
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | test_utils.rs | 21 // This channel allows the server to notify the client when it has shut down.
73 use std::sync::mpsc::channel;
77 let (tx, rx) = channel();
78 let (tx2, rx2) = channel();
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 26 use crate::sync::watch::{channel, Receiver, Sender};
37 let (tx, _) = channel(()); in default()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
| H A D | mod.rs | 25 // This channel allows the server to notify the client when it has shut down.
66 use std::sync::mpsc::channel;
71 let (rx, tx) = channel();
72 let (rx2, tx2) = channel();
175 use std::sync::mpsc::channel;
181 let (rx, tx) = channel();
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 31 // This channel allows the server to notify the client when it is up and running.
34 // This channel allows the client to notify the server when it is ready to shut down.
37 // This channel allows the server to notify the client when it has shut down.
60 let (tx, rx) = std::sync::mpsc::channel();
74 .expect("Handle send channel (Server-Half) be closed unexpectedly");
86 let (tx, rx) = std::sync::mpsc::channel();
96 .expect("Start channel (Server-Half) be closed unexpectedly");
105 .expect("Handle send channel (Server-Half) be closed unexpectedly");
119 use tokio::sync::mpsc::channel;
121 let (start_tx, start_rx) = channel
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_bounded_mpsc.rs | 30 let (sender, mut receiver) = channel(10);
99 use tokio::sync::mpsc::channel;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | select.rs | 59 /// SDV test cases for select! oneshot::channel usage
62 /// 1. Creates two oneshot::channel and send message.
63 /// 2. Repeated uses select! until both channel return.
69 let (tx1, mut rx1) = ylong_runtime::sync::oneshot::channel(); in sdv_new_select_channel()
70 let (tx2, mut rx2) = ylong_runtime::sync::oneshot::channel(); in sdv_new_select_channel()
|
| H A D | tcp_test.rs | 415 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_drop_out_context()
466 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_cancel()
511 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_cancel()
559 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_unexpected_eof()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 76 channel as bounded_channel, error::SendError, unbounded_channel,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 493 let (tx, rx) = crate::sync::oneshot::channel(); in ut_current_thread_io()
500 let (tx, rx) = crate::sync::oneshot::channel(); in ut_current_thread_io()
|
| H A D | async_pool.rs | 613 use std::sync::mpsc::channel;
765 let (tx, rx) = channel(); in ut_executor_mng_info_cancel()
794 let (tx, rx) = channel(); in ut_executor_mng_info_wake_up_all()
833 let (tx, rx) = channel(); in ut_executor_mng_info_wake_up_rand_one()
869 let (tx, rx) = channel(); in ut_executor_mng_info_wake_up_if_one_task_left()
914 let (tx, rx) = channel(); in ut_executor_mng_info_from_woken_to_sleep()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 487 let (tx, rx) = crate::sync::oneshot::channel(); in ut_sleep_drop()
|