update pktqueue

2016-06-05 20:01:54 +08:00 · 2016-06-05 20:01:54 +08:00 · eaf15b625c
commit eaf15b625c
parent e620324491
1 changed files with 1 additions and 1 deletions
--- 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
 				}
 			}