From fee2c37aa4b1badec5f29970c299733f2f7fb353 Mon Sep 17 00:00:00 2001 From: nathan Date: Tue, 27 Aug 2024 18:12:11 +0800 Subject: [PATCH] chore: disable multiple thread in group --- services/appflowy-collaborate/src/rt_server.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/appflowy-collaborate/src/rt_server.rs b/services/appflowy-collaborate/src/rt_server.rs index da46a295..d1e9cb0e 100644 --- a/services/appflowy-collaborate/src/rt_server.rs +++ b/services/appflowy-collaborate/src/rt_server.rs @@ -23,7 +23,7 @@ use crate::group::cmd::{GroupCommand, GroupCommandRunner, GroupCommandSender}; use crate::group::manager::GroupManager; use crate::indexer::IndexerProvider; use crate::metrics::CollabMetricsCalculate; -use crate::rt_server::collaboration_runtime::COLLAB_RUNTIME; + use crate::state::RedisConnectionManager; use crate::{spawn_metrics, CollabRealtimeMetrics, RealtimeClientWebsocketSink}; @@ -200,7 +200,7 @@ where let object_id = entry.key().clone(); let clone_notify = notify.clone(); - COLLAB_RUNTIME.spawn(runner.run(object_id, clone_notify)); + tokio::spawn(runner.run(object_id, clone_notify)); entry.insert(new_sender.clone()); // wait for the runner to be ready to handle the message.