packetfraame: Move stream flush to finish call

Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>

diff --git a/src/mgmtchannel.rs b/src/mgmtchannel.rs
index f4b2471caf186e7ac0234ead107e96e96a1a4946..a2fc2aa926b12fd4ed542c20f426dd3cd42f7425 100644 (file)
--- a/src/mgmtchannel.rs
+++ b/src/mgmtchannel.rs
@@ -83,7 +83,6 @@ impl MgmtChannel {
     let mut f = self.write.new_frame()?;
     rmp_serde::encode::write_named(&mut f, val)?;
     f.finish()?;
-    self.write.flush()?;
     trace!("wrote OK {:?}", val);
   }
 

diff --git a/src/packetframe.rs b/src/packetframe.rs
index bf05f2d462120f3251451afcaee81e6619f193da..c7c6d633660a26982c23d57a75f39831ebb7cc62 100644 (file)
--- a/src/packetframe.rs
+++ b/src/packetframe.rs
@@ -321,6 +321,7 @@ impl<W:Write> FrameWriter<W> {
         Err(SenderError) => CHUNK_ERR,
       })?;
       self.in_frame = None;
+      self.inner.flush()?;
     }
   }
 }