We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3360df4 commit 8345d5cCopy full SHA for 8345d5c
1 file changed
zenoh/src/api/cancellation.rs
@@ -28,6 +28,7 @@ use tokio::sync::{OwnedSemaphorePermit, Semaphore};
28
use zenoh_core::{Resolvable, Wait};
29
#[cfg(feature = "unstable")]
30
use zenoh_result::ZResult;
31
+use zenoh_runtime::ZRuntime;
32
33
#[zenoh_macros::pub_visibility_if_internal]
34
#[derive(Debug)]
@@ -72,7 +73,7 @@ impl SyncGroup {
72
73
74
pub(crate) fn wait(&self) {
75
let s = self.semaphore.clone();
- let _p = futures::executor::block_on(s.acquire_many(Self::max_permits()));
76
+ let _p = ZRuntime::Application.block_in_place(s.acquire_many(Self::max_permits()));
77
self.close();
78
}
79
0 commit comments