diff --git a/go.mod b/go.mod index a0a9909..acdcce5 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/Monibuca/plugin-rtmp/v3 go 1.13 require ( - github.com/Monibuca/engine/v3 v3.0.0-alpha2 + github.com/Monibuca/engine/v3 v3.0.0-alpha3 github.com/Monibuca/utils/v3 v3.0.0-alpha3 github.com/logrusorgru/aurora v2.0.3+incompatible ) diff --git a/go.sum b/go.sum index 6bf34f1..7bbe7e5 100644 --- a/go.sum +++ b/go.sum @@ -2,6 +2,8 @@ github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/Monibuca/engine/v3 v3.0.0-alpha2 h1:11rWc6Qnp3kuVwGh8XDXqRivUSWMyv+Au6wZDgNHPSc= github.com/Monibuca/engine/v3 v3.0.0-alpha2/go.mod h1:K5FB3wk+iS/nPc+NS4XwObYQV4gtF6klEwDxaVM0BsQ= +github.com/Monibuca/engine/v3 v3.0.0-alpha3 h1:NtFBMsu1nvEA09q64sW9xNzLdQ9RCKQXJlESM3GmGxU= +github.com/Monibuca/engine/v3 v3.0.0-alpha3/go.mod h1:K5FB3wk+iS/nPc+NS4XwObYQV4gtF6klEwDxaVM0BsQ= github.com/Monibuca/utils/v3 v3.0.0-alpha3 h1:n4Sq7mS1Iz8oBj2BcV4sXgKbZgix0fFLvjAfXYoiXl0= github.com/Monibuca/utils/v3 v3.0.0-alpha3/go.mod h1:3xYmhQbgAZBHLyIMteUCd1va+1z/xnd72B585mCaT3c= github.com/funny/slab v0.0.0-20180511031532-b1fad5e5d478 h1:Db9StoJ6RZN3YttC0Pm0I4Y5izITRYch3RMbT59BYN0= diff --git a/netStream.go b/netStream.go index 52fc8b1..b1dc76b 100644 --- a/netStream.go +++ b/netStream.go @@ -91,7 +91,6 @@ func processRtmp(conn net.Conn) { if msg.Body[1] != 0 { return } - va.ASC = msg.Body[2:] config1, config2 := msg.Body[2], msg.Body[3] //audioObjectType = (config1 & 0xF8) >> 3 // 1 AAC MAIN ISO/IEC 14496-3 subpart 4 @@ -150,7 +149,7 @@ func processRtmp(conn net.Conn) { nalus = nalus[nalulen+nalulenSize:] } } - close(stream.WaitPub) + close(vt.WaitFirst) } for { if msg, err := nc.RecvMessage(); err == nil {