Searched refs:Channel (Results 1 - 3 of 3) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/
H A D	mod.rs	35 pub(crate) struct Channel<C: Container> { 40 impl<C: Container> Channel<C> { impls 41 fn new(chan: C) -> Channel<C> { in new() 42 Channel { in new() 50 let channel = Arc::new(Channel::new(chan)); 55 inner: Arc<Channel<C>>, 68 fn new(channel: Arc<Channel<C>>) -> Tx<C> { in new() 92 inner: Arc<Channel<C>>, 96 fn new(channel: Arc<Channel<C>>) -> Rx<C> { in new()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A D	oneshot.rs	59 /// Channel is closed. 85 let channel = Arc::new(Channel::new()); in channel() 137 channel: Arc<Channel<T>>, 271 channel: Arc<Channel<T>>, 409 struct Channel<T> { structure names 421 impl<T> Channel<T> { impls 422 fn new() -> Channel<T> { in new() 423 Channel { in new() 445 unsafe impl<T: Send> Send for Channel<T> {} 446 unsafe impl<T: Send> Sync for Channel< [all...]
H A D	watch.rs	53 let channel = Arc::new(Channel::new(value)); in channel() 85 channel: Arc<Channel<T>>, 275 channel: Arc<Channel<T>>, 536 struct Channel<T> { structure names 543 impl<T> Channel<T> { impls 544 fn new(value: T) -> Channel<T> { in new() 545 Channel { in new() 559 impl<T: Debug> Debug for Channel<T> { 562 f.debug_struct("Channel")

Completed in 2 milliseconds

Indexes created Thu Nov 07 10:32:03 CST 2024