diff --git a/demuxer.go b/demuxer.go
index af6c029..f6e8a29 100644
--- a/demuxer.go
+++ b/demuxer.go
@@ -116,7 +116,7 @@ func (self *Demuxer) readTSPacket() (err error) {
 						}
 					}
 					self.pktque = &pktqueue.Queue{}
-					self.pktque.Alloc(len(self.streams))
+					self.pktque.Alloc(self.Streams())
 					self.pktque.Poll = self.poll
 				}
 			}