Searched refs:bounded_channel (Results 1 – 7 of 7) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | mpsc_test.rs | 19 use ylong_runtime::sync::mpsc::{bounded_channel, unbounded_channel};
104 let (tx, mut rx) = bounded_channel::<i32>(1); in sdv_bounded_send_recv_test()
126 let (tx, mut rx) = bounded_channel::<i32>(3); in sdv_bounded_send_recv_drop_test()
149 let (tx, mut rx) = bounded_channel::<i32>(1); in sdv_bounded_try_send_try_recv_test()
168 let (tx, mut rx) = bounded_channel(1); in sdv_bounded_send_timeout_recv_timeout_test()
198 let (tx, rx) = bounded_channel::<i32>(1); in sdv_mpsc_is_closed()
220 let (tx, _) = bounded_channel::<i32>(1); in sdv_mpsc_is_same()
221 let (tx2, _) = bounded_channel::<i32>(1); in sdv_mpsc_is_same()
250 let (tx, mut rx) = bounded_channel(10); in sdv_mpsc_len()
296 let (tx, mut rx) = bounded_channel(10); in sdv_multi_send_recv_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_bounded_mpsc.rs | 64 let (sender, mut receiver) = bounded_channel(10);
115 use ylong_runtime::sync::mpsc::bounded_channel;
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 76 channel as bounded_channel, error::SendError, unbounded_channel,
105 bounded_channel, unbounded_channel, BoundedReceiver, BoundedSender,
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| H A D | mod.rs | 19 pub use bounded::{bounded_channel, BoundedReceiver, BoundedSender};
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 165 bounded_channel, unbounded_channel, AsyncRead, AsyncWrite, AsyncWriteExt, BoundedReceiver,
335 let (resp_tx, resp_rx) = bounded_channel(allow_num); in launch()
417 let (tx, rx) = bounded_channel::<RespMessage>(self.allow_cached_frames); in send_frame_to_controller()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 117 pub fn bounded_channel<T>(number: usize) -> (BoundedSender<T>, BoundedReceiver<T>) { in bounded_channel() function
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 456 let (resp_tx, resp_rx) = ylong_runtime::sync::mpsc::bounded_channel(20); in ut_http2_body_poll_read()
|