diff --git a/src/decoder.rs b/src/decoder.rs index f69a42c..f1407e0 100644 --- a/src/decoder.rs +++ b/src/decoder.rs @@ -265,7 +265,17 @@ impl FfmpegDemuxer { } impl FfmpegDemuxer { - fn pump (&mut self) -> Result < + fn pump (&mut self) -> Result { + while let Some ((stream, packet)) = self.input_ctx.packets ().next () { + if stream.index () == self.best_stream_idx { + // tracing::trace! ("demuxed packet"); + self.decoder.send_packet (&packet)?; + return Ok (true); + } + } + + Ok (false) + } } use crate::net_reader::NetReader;