diff --git a/internal/core/rtmp_conn.go b/internal/core/rtmp_conn.go index 38dd8856..aaed6edf 100644 --- a/internal/core/rtmp_conn.go +++ b/internal/core/rtmp_conn.go @@ -552,9 +552,6 @@ func (c *rtmpConn) runPublish(ctx context.Context) error { for _, byts := range bytss { onFrame(audioTrackID, byts) } - - default: - return fmt.Errorf("ERR: unexpected packet: %v", pkt.Type) } } } diff --git a/internal/core/rtmp_source.go b/internal/core/rtmp_source.go index c9ce52e0..dae9a776 100644 --- a/internal/core/rtmp_source.go +++ b/internal/core/rtmp_source.go @@ -241,9 +241,6 @@ func (s *rtmpSource) runInner() bool { for _, byts := range bytss { onFrame(audioTrackID, byts) } - - default: - return fmt.Errorf("ERR: unexpected packet: %v", pkt.Type) } } }()