We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 454cf5d commit 40eec20Copy full SHA for 40eec20
pubsub/examples/pubsub.rs
@@ -39,7 +39,7 @@ fn main() {
39
// or drop(subscriber)
40
41
loop {
42
- if is_done.load(atomic::Ordering::AcqRel) {
+ if is_done.load(atomic::Ordering::SeqCst) {
43
return;
44
}
45
@@ -56,7 +56,7 @@ fn main() {
56
}),
57
("remove_hello", move |_id: SubscriptionId, _| {
58
println!("Closing subscription");
59
- is_done2.store(true, atomic::Ordering::AcqRel);
+ is_done2.store(true, atomic::Ordering::SeqCst);
60
futures::future::ok(Value::Bool(true))
61
62
);
0 commit comments