diff --git a/pkg/rtmp/client_session.go b/pkg/rtmp/client_session.go index 94d6b97..a8ad4b1 100644 --- a/pkg/rtmp/client_session.go +++ b/pkg/rtmp/client_session.go @@ -662,7 +662,10 @@ func (s *ClientSession) notifyDoResultSucc() { } s.hasNotifyDoResultSucc = true - s.conn.ModWriteChanSize(s.option.WriteChanSize) + if s.option.WriteChanSize > 0 { + s.conn.ModWriteChanSize(s.option.WriteChanSize) + } + //pull有可能还需要小包发送,不使用缓存 if s.sessionStat.BaseType() == base.SessionBaseTypePushStr { s.conn.ModWriteBufSize(s.option.WriteBufSize)