increase channel handler capacity

Musixal · Oct 7, 2024 · e1d6bf6 · e1d6bf6
1 parent 04f4526
commit e1d6bf6
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/internal/client/transport/tcp.go b/internal/client/transport/tcp.go
@@ -187,8 +187,8 @@ func (c *TcpTransport) poolMaintainer() {
 }
 
 func (c *TcpTransport) channelHandler() {
-	msgChan := make(chan byte, 100)
-	errChan := make(chan error, 100)
+	msgChan := make(chan byte, 1000)
+	errChan := make(chan error, 1000)
 
 	// Goroutine to handle the blocking ReceiveBinaryString
 	go func() {

diff --git a/internal/client/transport/tcpmux.go b/internal/client/transport/tcpmux.go
@@ -202,8 +202,8 @@ func (c *TcpMuxTransport) poolMaintainer() {
 }
 
 func (c *TcpMuxTransport) channelHandler() {
-	msgChan := make(chan byte, 100)
-	errChan := make(chan error, 100)
+	msgChan := make(chan byte, 1000)
+	errChan := make(chan error, 1000)
 
 	// Goroutine to handle the blocking ReceiveBinaryString
 	go func() {

diff --git a/internal/client/transport/ws.go b/internal/client/transport/ws.go
@@ -154,8 +154,8 @@ func (c *WsTransport) poolMaintainer() {
 }
 
 func (c *WsTransport) channelHandler() {
-	msgChan := make(chan byte, 100)
-	errChan := make(chan error, 100)
+	msgChan := make(chan byte, 1000)
+	errChan := make(chan error, 1000)
 
 	// Goroutine to handle the blocking ReceiveBinaryString
 	go func() {

diff --git a/internal/client/transport/wsmux.go b/internal/client/transport/wsmux.go
@@ -167,8 +167,8 @@ func (c *WsMuxTransport) poolMaintainer() {
 }
 
 func (c *WsMuxTransport) channelHandler() {
-	msgChan := make(chan byte, 100)
-	errChan := make(chan error, 100)
+	msgChan := make(chan byte, 1000)
+	errChan := make(chan error, 1000)
 
 	// Goroutine to handle the blocking ReceiveBinaryString
 	go func() {