MCPcopy Create free account
hub / github.com/MegEngine/MegFlow / notify

Method notify

flow-rs/src/debug/feature.rs:35–43  ·  view source on GitHub ↗
(&self)

Source from the content-addressed store, hash-verified

33 }
34
35 pub fn notify(&self) {
36 if self
37 .enable
38 .compare_exchange(false, true, Ordering::SeqCst, Ordering::SeqCst)
39 .is_ok()
40 {
41 self.lock_ops.notify(usize::MAX);
42 }
43 }
44 #[allow(dead_code)]
45 pub async fn wait(&self) {
46 let mut listener = None;

Callers 7

closeMethod · 0.80
try_sendMethod · 0.80
sendMethod · 0.80
dropMethod · 0.80
try_recvMethod · 0.80
recvMethod · 0.80
closeMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected