WithDecoderConcurrency (#95)

ohkinozomu · Nov 28, 2023 · 835d5b3 · 835d5b3
1 parent 64c77ed
commit 835d5b3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/internal/agent/agent.go b/internal/agent/agent.go
@@ -202,7 +202,10 @@ func newServer(c AgentConfig) server {
 		c.Logger.Fatal(err.Error())
 	}
 
-	decoder, err := zstd.NewReader(nil)
+	decoder, err := zstd.NewReader(
+		nil,
+		zstd.WithDecoderConcurrency(1),
+	)
 	if err != nil {
 		c.Logger.Fatal(err.Error())
 	}

diff --git a/internal/hub/server.go b/internal/hub/server.go
@@ -137,7 +137,10 @@ func newClient(c HubConfig, payloadCh chan []byte) *autopaho.ConnectionManager {
 }
 
 func newServer(c HubConfig) server {
-	decoder, err := zstd.NewReader(nil)
+	decoder, err := zstd.NewReader(
+		nil,
+		zstd.WithDecoderConcurrency(1),
+	)
 	if err != nil {
 		c.Logger.Fatal(err.Error())
 	}