wip cmds

diff --git a/src/cmdlistener.rs b/src/cmdlistener.rs
index 4173fe2cbfe43206a55e68df8b40d02bcaa63acf..07d1736fa3adf9a5370feafdc946647e4f1f2ef0 100644 (file)
--- a/src/cmdlistener.rs
+++ b/src/cmdlistener.rs
@@ -36,11 +36,16 @@ type CSE = anyhow::Error;
 impl CommandStream<'_> {
   #[throws(CSE)]
   pub fn mainloop(mut self) {
-    for l in &mut self.read {
-      let l = l.context("read")?;
-      decode_and_process(&mut self, &l)?;
-      write!(&mut self.write, "\n")?;
-      self.write.flush()?;
+    loop {
+      match self.read.next() {
+        None => break,
+        Some(l) => {
+          let l = l.context("read")?;
+          decode_and_process(&mut self, &l)?;
+          write!(&mut self.write, "\n")?;
+          self.write.flush()?;
+        },
+      }
     }
   }
 }

diff --git a/src/commands.rs b/src/commands.rs
index f9b72f7eba4395c57e4c86db881510e7481facdc..1436516b03a34cd77200ac4662b31e61f9021565 100644 (file)
--- a/src/commands.rs
+++ b/src/commands.rs
@@ -5,7 +5,7 @@ use crate::imports::*;
 pub enum MgmtCommand {
   Noop { },
   SetScope(ManagementScope),
-  AddPiece(Box<dyn PieceSpec>),
+//  AddPiece(Box<dyn PieceSpec>),
 }
 
 #[derive(Debug,Serialize,Deserialize)]