From eaf15b625cf7a85e4546cc6917b536c8945900d6 Mon Sep 17 00:00:00 2001
From: nareix <hi.nareix@gmail.com>
Date: Sun, 5 Jun 2016 20:01:54 +0800
Subject: [PATCH] update pktqueue

---
 demuxer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
 				}
 			}