From 18369c161fc77c7957936f3f4d3b660cd52ce67c Mon Sep 17 00:00:00 2001
From: Alexandr Romanenko <alex.romanenko@cube.dev>
Date: Mon, 6 Nov 2023 04:22:44 +0300
Subject: [PATCH] fix(cubestore): Fix broadcasting for worker services

---
 rust/cubestore/cubestore/src/cluster/worker_services.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/rust/cubestore/cubestore/src/cluster/worker_services.rs b/rust/cubestore/cubestore/src/cluster/worker_services.rs
index 2544f490f198f..c703afcc05360 100644
--- a/rust/cubestore/cubestore/src/cluster/worker_services.rs
+++ b/rust/cubestore/cubestore/src/cluster/worker_services.rs
@@ -246,13 +246,13 @@ impl<P: Callable> ServicesClientImpl<P> {
                     payload: message,
                 };
 
+                let mut broadcast_rx = message_broadcast_tx.subscribe();
+
                 if let Err(e) = sender.send(ipc_message) {
                     log::error!("Error while sending ipc service request: {:?}", e);
                     break;
                 }
 
-                let mut broadcast_rx = message_broadcast_tx.subscribe();
-
                 cube_ext::spawn(async move {
                     loop {
                         let broadcast_message = tokio::select! {