clean up ring buffer

Author: githubsands

ring-buffer/src/lib.rs

@@ -27,7 +27,6 @@ impl fmt::Debug for BufferError {
     }
 }
 
-// Implement the Error trait
 impl Error for BufferError {
     fn source(&self) -> Option<&(dyn Error + 'static)> {
         match self {
@@ -68,26 +67,7 @@ impl RingBuffer {
             },
         }
     }
-    /*
-    pub enum TryRecvError {
-        /// A message could not be received because the channel is empty.
-        ///
-        /// If this is a zero-capacity channel, then the error indicates that there was no sender
-        /// available to send a message at the time.
-        Empty,
 
-        /// The message could not be received because the channel is empty and disconnected.
-        Disconnected,
-    }
-        */
-
-    /*
-    if let Ok(order) = self.depth_consumer.recv() {
-        self.buffer.push_back(order)
-    } else {
-        warn!("no depth to receive")
-    }
-    */
     pub fn pop_depth(&mut self) -> Option<DepthUpdate> {
         if let Some(order) = self.buffer.pop_front() {
             info!("pop_depth in rb");
@@ -98,24 +78,15 @@ impl RingBuffer {
     }
     pub fn push_back(&mut self, item: DepthUpdate) {
         if self.buffer.len() == self.size {
-            // get rid of the oldest item in the ring buffer before
-            // pushing an item in the back
             self.buffer.pop_front();
         }
         self.buffer.push_back(item);
     }
-    // possibly remove this function
+
     pub fn push_front(&mut self, item: DepthUpdate) {
         if self.buffer.len() == self.size {
             self.buffer.pop_back();
         }
         self.buffer.push_front(item);
     }
-    fn pop_front(&mut self) -> Option<DepthUpdate> {
-        self.buffer.pop_front()
-    }
-    // possibly remove this function
-    pub fn pop_back(&mut self) -> Option<DepthUpdate> {
-        self.buffer.pop_back()
-    }
 }