| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 49 pub struct UnboundedSender<T> { struct
53 impl<T> Clone for UnboundedSender<T> { implementation
55 UnboundedSender { in clone()
98 pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>) { in unbounded_channel()
101 (UnboundedSender::new(tx), UnboundedReceiver::new(rx)) in unbounded_channel()
104 impl<T> UnboundedSender<T> { implementation
105 fn new(channel: Tx<Queue<T>>) -> UnboundedSender<T> { in new()
106 UnboundedSender { channel } in new()
190 impl<T> Drop for UnboundedSender<T> { implementation
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | keeper.rs | 17 use ylong_runtime::sync::mpsc::UnboundedSender;
27 tx: UnboundedSender<TaskManagerEvent>,
85 fn count_down(tx: UnboundedSender<TaskManagerEvent>) -> JoinHandle<()> { in count_down()
89 async fn unload_sa(tx: UnboundedSender<TaskManagerEvent>) { in unload_sa()
|
| /ohos5.0/base/request/request/services/src/service/client/ |
| H A D | manager.rs | 16 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
29 tx: UnboundedSender<ClientEvent>,
33 pub(crate) fn new(tx: UnboundedSender<ClientEvent>) -> Self { in new()
54 clients: HashMap<u64, (UnboundedSender<ClientEvent>, i32)>,
|
| H A D | mod.rs | 23 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
149 pub(crate) fn constructor(pid: u64) -> Option<(UnboundedSender<ClientEvent>, i32)> { in constructor()
|
| /ohos5.0/base/request/request/services/src/service/run_count/ |
| H A D | manager.rs | 16 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
29 tx: UnboundedSender<RunCountEvent>,
33 pub(crate) fn new(tx: UnboundedSender<RunCountEvent>) -> Self { in new()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 78 UnboundedSender,
106 UnboundedReceiver, UnboundedSender,
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 166 BoundedSender, SendError, UnboundedReceiver, UnboundedSender, WriteHalf,
213 pub(crate) sender: UnboundedSender<ReqMessage>,
224 pub(crate) sender: UnboundedSender<ReqMessage>,
330 input_channel: (UnboundedSender<Frame>, UnboundedReceiver<Frame>), in launch()
401 sender: UnboundedSender<ReqMessage>, in new()
500 input_tx: &UnboundedSender<Frame>, in poll_blocked_message()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 19 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
348 pub(crate) tx: UnboundedSender<TaskManagerEvent>,
352 pub(crate) fn new(tx: UnboundedSender<TaskManagerEvent>) -> Self { in new()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| H A D | mod.rs | 20 pub use unbounded::{unbounded_channel, UnboundedReceiver, UnboundedSender};
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 25 use crate::runtime::{BoundedReceiver, UnboundedReceiver, UnboundedSender};
45 input_tx: UnboundedSender<Frame>,
127 input_tx: UnboundedSender<Frame>, in new()
|
| H A D | streams.rs | 22 use crate::runtime::UnboundedSender;
374 sender: &UnboundedSender<Frame>, in window_update_conn()
386 sender: &UnboundedSender<Frame>, in window_update_streams()
|