[patch] prev pr patch

pkg/base/avpacket_stream.go

@@ -15,7 +15,7 @@ type (
 
 const (
 	AvPacketStreamAudioFormatUnknown AvPacketStreamAudioFormat = 0
-	AvPacketStreamAudioFormatRawAac AvPacketStreamAudioFormat = 1
+	AvPacketStreamAudioFormatRawAac  AvPacketStreamAudioFormat = 1
 
 	AvPacketStreamVideoFormatUnknown AvPacketStreamVideoFormat = 0
 	AvPacketStreamVideoFormatAvcc    AvPacketStreamVideoFormat = 1

pkg/logic/logic.go

@@ -22,8 +22,8 @@ type ILalServer interface {
 	// AddCustomizePubSession 定制化增强功能。业务方可以将自己的流输入到 ILalServer 中
 	//
 	// @example 示例见 lal/app/demo/customize_lalserver
-  //
-  // @doc 文档见 <lalserver二次开发 - pub接入自定义流> https://pengrl.com/lal/#/customize_pub
+	//
+	// @doc 文档见 <lalserver二次开发 - pub接入自定义流> https://pengrl.com/lal/#/customize_pub
 	//
 	AddCustomizePubSession(streamName string) (ICustomizePubSessionContext, error)
 

pkg/rtmp/client_pull_session.go

@@ -26,7 +26,7 @@ type PullSessionOption struct {
 	ReadAvTimeoutMs      int
 	ReadBufSize          int // io层读取音视频数据时的缓冲大小，如果为0，则没有缓冲
 	HandshakeComplexFlag bool
-	PeerWinAckSize int
+	PeerWinAckSize       int
 }
 
 var defaultPullSessionOption = PullSessionOption{
@@ -34,7 +34,7 @@ var defaultPullSessionOption = PullSessionOption{
 	ReadAvTimeoutMs:      0,
 	ReadBufSize:          0,
 	HandshakeComplexFlag: false,
-	PeerWinAckSize:0,
+	PeerWinAckSize:       0,
 }
 
 type ModPullSessionOption func(option *PullSessionOption)

pkg/rtmp/client_session.go

@@ -30,10 +30,10 @@ type ClientSession struct {
 	t      ClientSessionType
 	option ClientSessionOption
 
-	packer         *MessagePacker
-	chunkComposer  *ChunkComposer
-	urlCtx         base.UrlContext
-	hc             IHandshakeClient
+	packer        *MessagePacker
+	chunkComposer *ChunkComposer
+	urlCtx        base.UrlContext
+	hc            IHandshakeClient
 
 	conn                  connection.Connection
 	prevConnStat          connection.Stat
@@ -84,7 +84,7 @@ var defaultClientSessOption = ClientSessionOption{
 	WriteBufSize:         0,
 	WriteChanSize:        0,
 	HandshakeComplexFlag: false,
-	PeerWinAckSize:0,
+	PeerWinAckSize:       0,
 }
 
 type ModClientSessionOption func(option *ClientSessionOption)
@@ -554,7 +554,7 @@ func (s *ClientSession) doProtocolControlMessage(stream *Stream) error {
 }
 
 func (s *ClientSession) doRespAcknowledgement(stream *Stream) error {
-	//参考srs代码
+	// https://github.com/q191201771/lal/pull/154
 	if s.option.PeerWinAckSize <= 0 {
 		return nil
 	}