diff --git a/src/net/data_stream.rs b/src/net/data_stream.rs index 8560b29..f8eb921 100644 --- a/src/net/data_stream.rs +++ b/src/net/data_stream.rs @@ -139,6 +139,7 @@ pub fn setup_streaming( (generator, stream) } +#[derive(Debug)] struct StreamFrame { buffer: Box<[u8; FRAME_SIZE], Init>, offset: usize, @@ -249,15 +250,9 @@ impl FrameGenerator { current_frame.add_batch::<_, T>(f); if current_frame.is_full::() { - if self - .queue + self.queue .enqueue(self.current_frame.take().unwrap()) - .is_err() - { - // Given that the queue is the same size as the number of frames available, this - // should never occur. - panic!("Frame enqueue failure") - } + .unwrap(); } } }