Remove deprecated-in-0.1.x APIs

src/proto/streams/buffer.rs

@@ -93,10 +93,12 @@ impl Deque {
         }
     }
 
+    /*
     pub fn peek_front<'a, T>(&self, buf: &'a Buffer<T>) -> Option<&'a T> {
         match self.indices {
             Some(idxs) => Some(&buf.slab[idxs.head].value),
             None => None,
         }
     }
+    */
 }

src/proto/streams/recv.rs

@@ -456,18 +456,6 @@ impl Recv {
         }
     }
 
-    pub fn body_is_empty(&self, stream: &store::Ptr) -> bool {
-        if !stream.state.is_recv_closed() {
-            return false;
-        }
-
-        stream
-            .pending_recv
-            .peek_front(&self.buffer)
-            .map(|event| !event.is_data())
-            .unwrap_or(true)
-    }
-
     pub fn is_end_stream(&self, stream: &store::Ptr) -> bool {
         if !stream.state.is_recv_closed() {
             return false;
@@ -1050,17 +1038,6 @@ impl Recv {
     }
 }
 
-// ===== impl Event =====
-
-impl Event {
-    fn is_data(&self) -> bool {
-        match *self {
-            Event::Data(..) => true,
-            _ => false,
-        }
-    }
-}
-
 // ===== impl Open =====
 
 impl Open {

src/proto/streams/streams.rs

@@ -1104,15 +1104,6 @@ impl OpaqueStreamRef {
             })
     }
 
-    pub fn body_is_empty(&self) -> bool {
-        let mut me = self.inner.lock().unwrap();
-        let me = &mut *me;
-
-        let stream = me.store.resolve(self.key);
-
-        me.actions.recv.body_is_empty(&stream)
-    }
-
     pub fn is_end_stream(&self) -> bool {
         let mut me = self.inner.lock().unwrap();
         let me = &mut *me;