diff --git a/network-client-okhttp/src/main/java/io/ably/lib/network/OkHttpWebSocketClient.java b/network-client-okhttp/src/main/java/io/ably/lib/network/OkHttpWebSocketClient.java index 7341eb71a..bcaaf1c1d 100644 --- a/network-client-okhttp/src/main/java/io/ably/lib/network/OkHttpWebSocketClient.java +++ b/network-client-okhttp/src/main/java/io/ably/lib/network/OkHttpWebSocketClient.java @@ -59,6 +59,11 @@ private WebSocketHandler(WebSocketListener listener) { this.listener = listener; } + @Override + public void onClosing(WebSocket webSocket, int code, String reason) { + webSocket.close(1000, null); + } + @Override public void onClosed(WebSocket webSocket, int code, String reason) { listener.onClose(code, reason);