Added TODO

asticode · Dec 9, 2017 · 12c55be · 12c55be
1 parent 40e33ae
commit 12c55be
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/demuxer.go b/demuxer.go
@@ -69,6 +69,8 @@ func OptPacketsParser(p PacketsParser) func(*Demuxer) {
 // NextPacket retrieves the next packet
 func (dmx *Demuxer) NextPacket() (p *Packet, err error) {
 	// Check ctx error
+	// TODO Handle ctx error another way since if the read blocks, everything blocks
+	// Maybe execute everything in a goroutine and listen the ctx channel in the same for loop
 	if err = dmx.ctx.Err(); err != nil {
 		return
 	}