make sure waiting for child thread; tag 0.0.5

Author: tiye

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "calcit_wss"
-version = "0.0.4"
+version = "0.0.5"
 authors = ["jiyinyiyong <[email protected]>"]
 edition = "2021"
 

Cargo.toml

@@ -2,7 +2,7 @@
 {} (:package |wss)
   :configs $ {} (:init-fn |wss.test/main!) (:reload-fn |wss.test/reload!)
     :modules $ []
-    :version |0.0.4
+    :version |0.0.5
   :files $ {}
     |wss.core $ {}
       :ns $ quote

calcit.cirru

@@ -35,7 +35,7 @@ pub fn wss_serve(
   let event_hub = simple_websockets::launch(port).expect("failed to listen on port 9001");
   println!("WebSocket server started at port {}", port);
 
-  spawn(move || {
+  let task = spawn(move || {
     loop {
       match event_hub.poll_event() {
         Event::Connect(client_id, responder) => {
@@ -90,6 +90,8 @@ pub fn wss_serve(
     }
   });
 
+  task.join().expect("running WebSocket server");
+
   Ok(Edn::Nil)
 }