reduce CPU usages; bump 0.0.4

tiye · tiye · commit 7a8947f41524 · 2021-11-10T02:04:43.000+08:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "calcit_wss"
-version = "0.0.3"
+version = "0.0.4"
 authors = ["jiyinyiyong <jiyinyiyong@gmail.com>"]
 edition = "2021"
 
diff --git a/README.md b/README.md
@@ -18,6 +18,14 @@ wss.core/wss-serve!
 
 Install to `~/.config/calcit/modules/`, compile and provide `*.{dylib,so}` file with `./build.sh`.
 
+### Develop
+
+Run buildin demo with:
+
+```bash
+cr -1 --init-fn wss.test/demo!
+```
+
 ### Workflow
 
 https://github.com/calcit-lang/dylib-workflow
diff --git a/calcit.cirru b/calcit.cirru
diff --git a/compact.cirru b/compact.cirru
@@ -2,7 +2,7 @@
 {} (:package |wss)
   :configs $ {} (:init-fn |wss.test/main!) (:reload-fn |wss.test/reload!)
     :modules $ []
-    :version |0.0.2
+    :version |0.0.4
   :files $ {}
     |wss.core $ {}
       :ns $ quote
diff --git a/src/lib.rs b/src/lib.rs
@@ -37,12 +37,7 @@ pub fn wss_serve(
 
   spawn(move || {
     loop {
-      let event = match event_hub.next_event() {
-        Some(e) => e,
-        None => continue,
-      };
-
-      match event {
+      match event_hub.poll_event() {
         Event::Connect(client_id, responder) => {
           {
             // add their Responder to our `clients` map:
@@ -68,6 +63,8 @@ pub fn wss_serve(
           ])]) {
             println!("Failed to handle disconnect: {}", e)
           }
+
+          break;
         }
         Event::Message(client_id, message) => match message {
           Message::Text(s) => {
