Skip to content

Commit 7073c17

Browse files
committed
Override onMessage w/ ByteString
1 parent 590278a commit 7073c17

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/OkHttpWebSocketWrapper.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import okhttp3.Response;
1818
import okhttp3.WebSocket;
1919
import okhttp3.WebSocketListener;
20+
import okio.ByteString;
2021

2122
class OkHttpWebSocketWrapper extends WebSocketWrapper {
2223
private WebSocket websocketClient;
@@ -85,6 +86,11 @@ public void onOpen(WebSocket webSocket, Response response) {
8586
public void onMessage(WebSocket webSocket, String message) {
8687
onReceive.invoke(message);
8788
}
89+
90+
@Override
91+
public void onMessage(WebSocket webSocket, ByteString bytes) {
92+
onReceive.invoke(bytes.utf8());
93+
}
8894

8995
@Override
9096
public void onClosing(WebSocket webSocket, int code, String reason) {

0 commit comments

Comments
 (0)