Searched refs:BoundedReceiver (Results 1 – 5 of 5) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 88 pub struct BoundedReceiver<T> { struct
117 pub fn bounded_channel<T>(number: usize) -> (BoundedSender<T>, BoundedReceiver<T>) { in bounded_channel()
120 (BoundedSender::new(tx), BoundedReceiver::new(rx)) in bounded_channel()
314 impl<T> BoundedReceiver<T> { implementation
315 fn new(channel: Rx<Array<T>>) -> BoundedReceiver<T> { in new()
316 BoundedReceiver { channel } in new()
519 impl<T> Drop for BoundedReceiver<T> { implementation
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 77 Receiver as BoundedReceiver, Sender as BoundedSender, UnboundedReceiver,
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,
269 receiver: Option<BoundedReceiver<RespMessage>>,
545 pub(crate) fn set_receiver(&mut self, receiver: BoundedReceiver<RespMessage>) { in set_receiver()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 25 use crate::runtime::{BoundedReceiver, UnboundedReceiver, UnboundedSender};
47 resp_rx: BoundedReceiver<OutputMessage>,
128 resp_rx: BoundedReceiver<OutputMessage>, in new()
|