Resetting buffers on rewind

asticode · Nov 26, 2017 · 041ea73 · 041ea73
1 parent c53695d
commit 041ea73
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/demuxer.go b/demuxer.go
@@ -184,6 +184,8 @@ func (dmx *Demuxer) NextData() (d *Data, err error) {
 
 // Rewind rewinds the demuxer reader
 func (dmx *Demuxer) Rewind() (n int64, err error) {
+	dmx.dataBuffer = []*Data{}
+	dmx.packetBuffer = newPacketBuffer()
 	if s, ok := dmx.r.(io.Seeker); ok {
 		if n, err = s.Seek(0, 0); err != nil {
 			err = errors.Wrap(err, "astits: seeking to 0 failed")