Home
last modified time | relevance | path

Searched refs:tx (Results 1 - 15 of 15) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dmpsc_test.rs29 let (tx, mut rx) = unbounded_channel(); in sdv_unbounded_send_recv_test()
35 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_test()
36 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_test()
37 drop(tx); in sdv_unbounded_send_recv_test()
49 let (tx, mut rx) = unbounded_channel(); in sdv_unbounded_send_recv_drop_test()
54 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_drop_test()
55 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_drop_test()
56 drop(tx); in sdv_unbounded_send_recv_drop_test()
68 let (tx, mut rx) = unbounded_channel(); in sdv_unbounded_send_try_recv_test()
70 assert!(tx in sdv_unbounded_send_try_recv_test()
[all...]
H A Dtcp_test.rs415 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_drop_out_context()
419 tx.send(addr).unwrap(); in sdv_tcp_drop_out_context()
466 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_cancel()
470 let _ = tx.send(addr); in sdv_tcp_cancel()
511 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_cancel()
515 tx.send(addr).unwrap(); in sdv_tcp_cancel()
559 let (tx, rx) = ylong_runtime::sync::oneshot::channel(); in sdv_tcp_unexpected_eof()
563 tx.send(addr).unwrap(); in sdv_tcp_unexpected_eof()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dwatch.rs43 /// let (tx, mut rx) = watch::channel(1);
49 /// let _ = tx.send(2);
54 let tx = Sender { in channel()
61 (tx, rx) in channel()
73 /// let (tx, mut rx) = watch::channel(1);
74 /// assert_eq!(tx.receiver_count(), 1);
80 /// let _ = tx.send(2);
99 /// let (tx, mut rx) = watch::channel(1);
105 /// let _ = tx.send(2);
132 /// let (tx, mu
[all...]
H A Doneshot.rs29 //! let (tx, rx) = oneshot::channel();
31 //! if let Err(_) = tx.send(6) {
71 /// let (tx, rx) = oneshot::channel();
73 /// if let Err(_) = tx.send(6) {
86 let tx = Sender { in channel()
90 (tx, rx) in channel()
102 /// let (tx, rx) = oneshot::channel();
104 /// if let Err(_) = tx.send(6) {
124 /// let (tx, rx) = oneshot::channel::<()>();
126 /// drop(tx);
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/
H A Dregistry.rs27 let (tx, _) = channel(()); in default()
28 Self { inner: tx } in default()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs152 let (tx, rx) = std::sync::mpsc::channel(); in sdv_async_h2_client_send_request()
161 tx.send(handle) in sdv_async_h2_client_send_request()
232 let (tx, rx) = std::sync::mpsc::channel(); in sdv_async_h2_client_send_request_concurrently()
241 tx.send(handle) in sdv_async_h2_client_send_request_concurrently()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs37 let (tx, _) = channel(()); in default()
39 inner: tx, in default()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs39 /// let (tx, mut rx) = unbounded_channel();
40 /// let tx2 = tx.clone();
41 /// assert!(tx.send(1).is_ok());
42 /// assert!(!tx.is_closed());
43 /// assert!(tx.is_same(&tx2));
70 /// let (tx, mut rx) = unbounded_channel();
72 /// assert!(tx.send(1).is_ok());
91 /// let (tx, mut rx) = unbounded_channel();
95 /// assert!(tx.send(1).is_ok());
100 let (tx, r in unbounded_channel()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dcurrent_thread.rs362 pub async fn ylong_tcp_server(tx: crate::sync::oneshot::Sender<SocketAddr>) {
365 tx.send(addr).unwrap();
493 let (tx, rx) = crate::sync::oneshot::channel(); in ut_current_thread_io()
494 let join_handle = spawner.spawn(ylong_tcp_server(tx)); in ut_current_thread_io()
500 let (tx, rx) = crate::sync::oneshot::channel(); in ut_current_thread_io()
502 spawner.block_on(ylong_tcp_server(tx)); in ut_current_thread_io()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs71 let (rx, tx) = channel();
80 server_shutdown: tx,
181 let (rx, tx) = channel();
244 server_shutdown: tx,
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dtest_utils.rs77 let (tx, rx) = channel();
120 tx.send(()).expect("server send order failed !");
H A Ddispatcher.rs432 let (tx, rx) = bounded_channel::<RespMessage>(self.allow_cached_frames);
436 sender: tx,
482 let mut tx = { variables
488 match tx.as_mut().poll(cx) {
496 self.curr_message.insert(stream_id, tx);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs40 /// let (tx, mut rx) = bounded_channel(1);
41 /// let tx2 = tx.clone();
43 /// assert!(tx.send(1).await.is_ok());
44 /// assert!(!tx.is_closed());
45 /// assert!(tx.is_same(&tx2));
75 /// let (tx, mut rx) = bounded_channel(1);
78 /// assert!(tx.send(1).await.is_ok());
106 /// let (tx, mut rx) = bounded_channel(1);
111 /// assert!(tx.send(1).await.is_ok());
119 let (tx, r in bounded_channel()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dmod.rs60 let (tx, rx) = std::sync::mpsc::channel();
66 tx.send(handle)
86 let (tx, rx) = std::sync::mpsc::channel();
97 tx.send(handle)
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dwheel.rs474 async fn udp_receiver(tx: crate::sync::oneshot::Sender<SocketAddr>) { in ut_sleep_drop()
477 tx.send(addr).unwrap(); in ut_sleep_drop()
487 let (tx, rx) = crate::sync::oneshot::channel(); in ut_sleep_drop()
489 tasks.push(crate::spawn(udp_receiver(tx))); in ut_sleep_drop()

Completed in 7 milliseconds