升级playblock

This commit is contained in:
dexter
2022-03-27 11:33:47 +08:00
parent cda1808f48
commit da93ad787e
2 changed files with 2 additions and 2 deletions

View File

@@ -116,7 +116,7 @@ func (pusher *RTMPPusher) Push() {
}) })
} else if response, ok := msg.MsgData.(*ResponsePublishMessage); ok { } else if response, ok := msg.MsgData.(*ResponsePublishMessage); ok {
if response.Infomation["code"] == NetStream_Publish_Start { if response.Infomation["code"] == NetStream_Publish_Start {
go pusher.PlayBlock(pusher) go pusher.PlayBlock()
} else { } else {
return return
} }

View File

@@ -154,7 +154,7 @@ func (config *RTMPConfig) ServeTCP(conn *net.TCPConn) {
sender.Begin() sender.Begin()
sender.Response(cmd.TransactionId, NetStream_Play_Reset, Level_Status) sender.Response(cmd.TransactionId, NetStream_Play_Reset, Level_Status)
sender.Response(cmd.TransactionId, NetStream_Play_Start, Level_Status) sender.Response(cmd.TransactionId, NetStream_Play_Start, Level_Status)
go sender.PlayBlock(sender) go sender.PlayBlock()
} }
} }
case RTMP_MSG_AUDIO: case RTMP_MSG_AUDIO: