Searched defs:channel (Results 1 – 5 of 5) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | oneshot.rs | 84 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel() function
85 let channel = Arc::new(Channel::new()); in channel() localVariable
137 channel: Arc<Channel<T>>, field
271 channel: Arc<Channel<T>>, field
|
| D | watch.rs | 52 pub fn channel<T>(value: T) -> (Sender<T>, Receiver<T>) { in channel() function
53 let channel = Arc::new(Channel::new(value)); in channel() localVariable
85 channel: Arc<Channel<T>>, field
275 channel: Arc<Channel<T>>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| D | mod.rs | 49 pub(crate) fn channel<C: Container>(chan: C) -> (Tx<C>, Rx<C>) { in channel() function
50 let channel = Arc::new(Channel::new(chan)); in channel() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| D | mod.rs | 50 channel: Tx<Queue<T>>, field
80 channel: Rx<Queue<T>>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| D | mod.rs | 55 channel: Tx<Array<T>>, field
89 channel: Rx<Array<T>>, field
|