apps/plugin-rtmp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtmp.git synced 2025-11-02 19:44:00 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: ignore release stream

Browse Source
This commit is contained in:
langhuihui
2023-06-17 17:10:22 +08:00
parent ab65902ec0
commit e1c1777455
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server.go
View File

@@ -106,14 +106,14 @@ func (config *RTMPConfig) ServeTCP(conn net.Conn) {
// CommandName: "releaseStream_error",
// TransactionId: cmd.TransactionId,
// }
s := engine.Streams.Get(nc.appName + "/" + cmd.StreamName)
if s != nil && s.Publisher != nil {
if p, ok := s.Publisher.(*RTMPReceiver); ok {
// m.CommandName = "releaseStream_result"
p.Stop()
delete(receivers, p.StreamID)
}
}
// s := engine.Streams.Get(nc.appName + "/" + cmd.StreamName)
// if s != nil && s.Publisher != nil {
// if p, ok := s.Publisher.(*RTMPReceiver); ok {
// // m.CommandName = "releaseStream_result"
// p.Stop()
// delete(receivers, p.StreamID)
// }
// }
// err = nc.SendMessage(RTMP_MSG_AMF0_COMMAND, m)
case *PublishMessage:
receiver := &RTMPReceiver{