TRY SPAWN

Author: tnull

src/io/vss_store.rs

@@ -120,7 +120,8 @@ impl KVStoreSync for VssStore {
 		let inner = Arc::clone(&self.inner);
 		let fut =
 			async move { inner.read_internal(primary_namespace, secondary_namespace, key).await };
-		tokio::task::block_in_place(move || internal_runtime.block_on(fut))
+		let spawned_fut = internal_runtime.spawn(fut);
+		tokio::task::block_in_place(move || internal_runtime.block_on(spawned_fut)).unwrap()
 	}
 
 	fn write(
@@ -150,7 +151,8 @@ impl KVStoreSync for VssStore {
 				)
 				.await
 		};
-		tokio::task::block_in_place(move || internal_runtime.block_on(fut))
+		let spawned_fut = internal_runtime.spawn(fut);
+		tokio::task::block_in_place(move || internal_runtime.block_on(spawned_fut)).unwrap()
 	}
 
 	fn remove(
@@ -179,7 +181,8 @@ impl KVStoreSync for VssStore {
 				)
 				.await
 		};
-		tokio::task::block_in_place(move || internal_runtime.block_on(fut))
+		let spawned_fut = internal_runtime.spawn(fut);
+		tokio::task::block_in_place(move || internal_runtime.block_on(spawned_fut)).unwrap()
 	}
 
 	fn list(&self, primary_namespace: &str, secondary_namespace: &str) -> io::Result<Vec<String>> {
@@ -192,7 +195,8 @@ impl KVStoreSync for VssStore {
 		let secondary_namespace = secondary_namespace.to_string();
 		let inner = Arc::clone(&self.inner);
 		let fut = async move { inner.list_internal(primary_namespace, secondary_namespace).await };
-		tokio::task::block_in_place(move || internal_runtime.block_on(fut))
+		let spawned_fut = internal_runtime.spawn(fut);
+		tokio::task::block_in_place(move || internal_runtime.block_on(spawned_fut)).unwrap()
 	}
 }