Skip to content

Commit

Permalink
Increased AsyncOutputStream shared queue size
Browse files Browse the repository at this point in the history
Signed-off-by: Artem Ananev <[email protected]>
  • Loading branch information
artemananiev committed Apr 12, 2024
1 parent 980ac5c commit 16330b4
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ public AsyncOutputStream(
this.outputStream = Objects.requireNonNull(outputStream, "outputStream must not be null");
this.workGroup = Objects.requireNonNull(workGroup, "workGroup must not be null");
this.queueSize = config.asyncStreamBufferSize();
this.streamQueue = new LinkedBlockingQueue<>(queueSize);
this.streamQueue = new LinkedBlockingQueue<>(queueSize * config.maxParallelSubtrees());
this.viewMessages = new HashMap<>();
this.alive = true;
this.timeSinceLastFlush = new StopWatch();
Expand Down

0 comments on commit 16330b4

Please sign in to comment.