Make websocket timeouts stay on IO threads.

This commit is contained in:
Cody Henthorne 2021-11-04 15:18:14 -04:00 committed by Greyson Parrelli
parent 65105fd3cb
commit 9827deffd3

View file

@ -208,7 +208,7 @@ public class WebSocketConnection extends WebSocketListener {
return single.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.timeout(10, TimeUnit.SECONDS);
.timeout(10, TimeUnit.SECONDS, Schedulers.io());
}
public synchronized void sendResponse(WebSocketResponseMessage response) throws IOException {