fix inert functionality

2023-07-12 11:53:05 -04:00 · 2023-07-12 11:53:05 -04:00 · f986f0dfa2
parent 9ed836d028
commit f986f0dfa2
1 changed files with 15 additions and 1 deletions
--- a/tfclient/src/nebulaworker_inert.rs
+++ b/tfclient/src/nebulaworker_inert.rs
@ -12,4 +12,18 @@ pub enum NebulaWorkerMessage {
    WakeUp,
 }

-pub fn nebulaworker_main(_config: TFClientConfig, _instance: String, _transmitter: ThreadMessageSender, _rx: Receiver<NebulaWorkerMessage>) {}
+pub fn nebulaworker_main(_config: TFClientConfig, _instance: String, _transmitter: ThreadMessageSender, rx: Receiver<NebulaWorkerMessage>) {
+    loop {
+        match rx.recv() {
+            Ok(msg) => match msg {
+                NebulaWorkerMessage::WakeUp => {
+                    continue;
+                },
+                NebulaWorkerMessage::Shutdown => {
+                    break;
+                }
+                _ => ()
+            }
+        }
+    }
+}