diff --git a/src/topology/controller.rs b/src/topology/controller.rs index 0087d5d3f7117..4e2066e5a814a 100644 --- a/src/topology/controller.rs +++ b/src/topology/controller.rs @@ -19,6 +19,10 @@ impl SharedTopologyController { Self(Arc::new(Mutex::new(inner))) } + pub fn blocking_lock(&self) -> MutexGuard { + self.0.blocking_lock() + } + pub async fn lock(&self) -> MutexGuard { self.0.lock().await }