From c2282ab5cb0d94dedb04978f2931c4078dbe3fee Mon Sep 17 00:00:00 2001 From: mpostma Date: Thu, 4 Mar 2021 19:30:13 +0100 Subject: [PATCH] non local udpate actor --- src/index_controller/update_actor.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/index_controller/update_actor.rs b/src/index_controller/update_actor.rs index a9e2a412a..4d1ff78fb 100644 --- a/src/index_controller/update_actor.rs +++ b/src/index_controller/update_actor.rs @@ -140,7 +140,7 @@ pub struct UpdateActorHandle { impl UpdateActorHandle where - D: AsRef<[u8]> + Sized + 'static, + D: AsRef<[u8]> + Sized + 'static + Sync + Send, { pub fn new(index_handle: IndexActorHandle, path: impl AsRef) -> Self { let path = path.as_ref().to_owned().join("updates"); @@ -148,7 +148,7 @@ where let store = MapUpdateStoreStore::new(index_handle, &path); let actor = UpdateActor::new(store, receiver, path); - tokio::task::spawn_local(actor.run()); + tokio::task::spawn(actor.run()); Self { sender } } @@ -207,5 +207,3 @@ impl UpdateStoreStore for MapUpdateStoreStore { } } } - -