aboutsummaryrefslogtreecommitdiff
path: root/src/worker_ws.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/worker_ws.rs')
-rw-r--r--src/worker_ws.rs8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/worker_ws.rs b/src/worker_ws.rs
index 25ec7b0..f038100 100644
--- a/src/worker_ws.rs
+++ b/src/worker_ws.rs
@@ -56,6 +56,9 @@ pub enum WorkerResponse {
key: String,
data: Map<String, Value>,
},
+ Config {
+ config: Value,
+ },
Error {
message: String,
},
@@ -73,6 +76,11 @@ async fn worker_websocket_inner(ws: WebSocket, state: Arc<RwLock<State>>) {
let worker = {
let mut g = state.write().await;
+ tx.send(WorkerResponse::Config {
+ config: g.config.clone(),
+ })
+ .await
+ .unwrap();
let id = g.worker_id_counter;
g.worker_id_counter += 1;
g.workers.insert(