[opt]rtsp sub 阻塞发送修改为异步发送

pkg/rtsp/rtsp.go

@@ -85,7 +85,8 @@ var (
 
 	unpackerItemMaxSize = 1024
 
-	serverCommandSessionReadBufSize = 256
+	serverCommandSessionReadBufSize   = 256
+	serverCommandSessionWriteChanSize = 1024
 
 	dummyRtpPacket = []byte{
 		0x80, 0x00, 0x00, 0x00,

pkg/rtsp/server_command_session.go

@@ -67,6 +67,7 @@ func NewServerCommandSession(observer ServerCommandSessionObserver, conn net.Con
 		observer:  observer,
 		conn: connection.New(conn, func(option *connection.Option) {
 			option.ReadBufSize = serverCommandSessionReadBufSize
+			option.WriteChanSize = serverCommandSessionWriteChanSize
 		}),
 	}