Framed::is_write_buf_empty() checks if write buffer is flushed

src/codec/framed.rs

@@ -135,6 +135,11 @@ impl<T, U> Framed<T, U> {
         &mut self.inner.get_mut().get_mut().0
     }
 
+    /// Check if write buffer is empty.
+    pub fn is_write_buf_empty(&self) -> bool {
+        self.inner.get_ref().is_empty()
+    }
+
     /// Check if write buffer is full.
     pub fn is_write_buf_full(&self) -> bool {
         self.inner.get_ref().is_full()

src/codec/framed_write.rs

@@ -77,6 +77,11 @@ impl<T, E> FramedWrite<T, E> {
     pub fn is_full(&self) -> bool {
         self.inner.is_full()
     }
+
+    /// Check if write buffer is empty.
+    pub fn is_empty(&self) -> bool {
+        self.inner.is_empty()
+    }
 }
 
 impl<T, E> FramedWrite<T, E>
@@ -194,6 +199,10 @@ impl<T> FramedWrite2<T> {
     pub fn is_full(&self) -> bool {
         self.buffer.len() >= self.high_watermark
     }
+
+    pub fn is_empty(&self) -> bool {
+        self.buffer.is_empty()
+    }
 }
 
 impl<T> FramedWrite2<T>

src/server/mod.rs

@@ -45,4 +45,4 @@ impl Token {
         self.0 += 1;
         token
     }
-}
+}