honeymoose/playwright-java
1
0
Fork 0
mirror of https://github.com/microsoft/playwright-java.git synced 2026-03-31 20:02:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(websocket): use incoming queue with unlimited capacity (#406)

Browse Source
This commit is contained in:
Yury Semikhatsky 2021-04-21 08:58:55 -07:00 committed by GitHub
parent 20322470b5
commit 2e57a7a101
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
playwright/src/main/java/com/microsoft/playwright/impl/WebSocketTransport.java
View File

@ -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;