From e1d6bf60a3a887ad83118815972ae645030edea2 Mon Sep 17 00:00:00 2001
From: Musixal <Musixal@users.noreply.github.com>
Date: Tue, 8 Oct 2024 00:02:45 +0330
Subject: [PATCH] increase channel handler capacity

---
 internal/client/transport/tcp.go    | 4 ++--
 internal/client/transport/tcpmux.go | 4 ++--
 internal/client/transport/ws.go     | 4 ++--
 internal/client/transport/wsmux.go  | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/internal/client/transport/tcp.go b/internal/client/transport/tcp.go
index 67d2864..f5908b6 100644
--- 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
index cdffb7d..800798f 100644
--- 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
index 33e22f9..7523e23 100644
--- 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
index 357624e..ee18e38 100644
--- 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() {