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() {