From f551dbfa655763898d63239c5307df37e5f63c91 Mon Sep 17 00:00:00 2001
From: q191201771 <191201771@qq.com>
Date: Tue, 3 May 2022 10:32:56 +0800
Subject: [PATCH] [patch] prev pr patch

---
 pkg/base/avpacket_stream.go     |  2 +-
 pkg/logic/logic.go              |  4 ++--
 pkg/rtmp/client_pull_session.go |  4 ++--
 pkg/rtmp/client_session.go      | 12 ++++++------
 4 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/pkg/base/avpacket_stream.go b/pkg/base/avpacket_stream.go
index 899a3f9..7c5036b 100644
--- a/pkg/base/avpacket_stream.go
+++ b/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
diff --git a/pkg/logic/logic.go b/pkg/logic/logic.go
index 928a69d..914df03 100644
--- a/pkg/logic/logic.go
+++ b/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)
 
diff --git a/pkg/rtmp/client_pull_session.go b/pkg/rtmp/client_pull_session.go
index 6ea7162..e2cde5e 100644
--- a/pkg/rtmp/client_pull_session.go
+++ b/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)
diff --git a/pkg/rtmp/client_session.go b/pkg/rtmp/client_session.go
index dcd4a46..ae40905 100644
--- a/pkg/rtmp/client_session.go
+++ b/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
 	}