diff --git a/pkg/logic/group.go b/pkg/logic/group.go index 95b2dc6..e513f9e 100644 --- a/pkg/logic/group.go +++ b/pkg/logic/group.go @@ -199,12 +199,6 @@ func (group *Group) broadcastRTMP(msg rtmp.AVMsg) { } } - lastGOP := group.gopCache.LastGOP() - if lastGOP != nil { - for _, item := range lastGOP.data { - _ = session.AsyncWrite(item) - } - } session.IsFresh = false } @@ -231,12 +225,6 @@ func (group *Group) broadcastRTMP(msg rtmp.AVMsg) { } } - lastGOP := group.httpflvGopCache.LastGOP() - if lastGOP != nil { - for _, item := range lastGOP.data { - session.WriteRawPacket(item) - } - } session.IsFresh = false }