From 2e57a7a101f5ef06d7bf111fc52eca50bd872016 Mon Sep 17 00:00:00 2001
From: Yury Semikhatsky <yurys@chromium.org>
Date: Wed, 21 Apr 2021 08:58:55 -0700
Subject: [PATCH] fix(websocket): use incoming queue with unlimited capacity
 (#406)

---
 .../com/microsoft/playwright/impl/WebSocketTransport.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/playwright/src/main/java/com/microsoft/playwright/impl/WebSocketTransport.java b/playwright/src/main/java/com/microsoft/playwright/impl/WebSocketTransport.java
index 0c35cf20..89fc36d1 100644
--- a/playwright/src/main/java/com/microsoft/playwright/impl/WebSocketTransport.java
+++ b/playwright/src/main/java/com/microsoft/playwright/impl/WebSocketTransport.java
@@ -23,14 +23,14 @@ import org.java_websocket.handshake.ServerHandshake;
 import java.io.IOException;
 import java.net.URI;
 import java.time.Duration;
-import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 
 
 class WebSocketTransport implements Transport {
-  private final BlockingQueue<String> incoming = new ArrayBlockingQueue<>(1000);
+  private final BlockingQueue<String> incoming = new LinkedBlockingQueue<>();
   private final ClientConnection clientConnection;
   private boolean isClosed;
   private volatile Exception lastError;