wip: sketch spawning processes

cablehead · Jun 7, 2024 · 992c611 · 992c611
1 parent 2144a0d
commit 992c611
Showing 1 changed file with 20 additions and 9 deletions.
diff --git a/src/spawn.rs b/src/spawn.rs
@@ -35,15 +35,23 @@ pub async fn spawn(mut store: Store) -> Result<(), Box<dyn std::error::Error + S
 
             loop {
                 tokio::select! {
-                    Some(frame) = recver.recv() => {
-                        eprintln!("FRAME: {:?}", &frame.topic);
-                        if frame.topic == "ws.send" {
-                            let content = store.cas_read(&frame.hash.unwrap()).await.unwrap();
-                            let mut content = content;
-                            content.push(b'\n');
-                            eprintln!("CONTENT: {}", std::str::from_utf8(&content).unwrap());
-                            if let Err(e) = stdin.write_all(&content).await {
-                                eprintln!("Failed to write to stdin: {}", e);
+                    frame = recver.recv() => {
+                        match frame {
+                            Some(frame) => {
+                                eprintln!("FRAME: {:?}", &frame.topic);
+                                if frame.topic == "ws.send" {
+                                    let content = store.cas_read(&frame.hash.unwrap()).await.unwrap();
+                                    let mut content = content;
+                                    content.push(b'\n');
+                                    eprintln!("CONTENT: {}", std::str::from_utf8(&content).unwrap());
+                                    if let Err(e) = stdin.write_all(&content).await {
+                                        eprintln!("Failed to write to stdin: {}", e);
+                                        break;
+                                    }
+                                }
+                            },
+                            None => {
+                                eprintln!("Receiver closed");
                                 break;
                             }
                         }
@@ -82,5 +90,8 @@ pub async fn spawn(mut store: Store) -> Result<(), Box<dyn std::error::Error + S
     let _ = child.wait().await;
     eprintln!("child: outie");
 
+    let _ = stop_tx.send(true);
+    eprintln!("adios spawn");
+
     Ok(())
 }