- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for onMessage (0.7 sec)
-
okhttp/src/test/java/okhttp3/AutobahnTester.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} else { events.add(Open(webSocket, response)) } } override fun onMessage( webSocket: WebSocket, bytes: ByteString, ) { Platform.get().log("[WS $name] onMessage", Platform.INFO, null) val delegate = delegate if (delegate != null) { this.delegate = null delegate.onMessage(webSocket, bytes) } else { events.add(Message(bytes = bytes)) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
webSocket.send(ByteString.decodeHex("deadbeef")); webSocket.close(1000, "Goodbye, World!"); } @Override public void onMessage(WebSocket webSocket, String text) { System.out.println("MESSAGE: " + text); } @Override public void onMessage(WebSocket webSocket, ByteString bytes) { System.out.println("MESSAGE: " + bytes.hex()); }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
@Throws(IOException::class) override fun onReadMessage(text: String) { listener.onMessage(this, text) } @Throws(IOException::class) override fun onReadMessage(bytes: ByteString) { listener.onMessage(this, bytes) } @Synchronized override fun onReadPing(payload: ByteString) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
clientListener.assertOpen() val server = serverListener.assertOpen() val e = RuntimeException() clientListener.setNextEventDelegate( object : WebSocketListener() { override fun onMessage( webSocket: WebSocket, text: String, ) { throw e } }, ) server.send("Hello, WebSockets!") clientListener.assertFailure(e)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
okhttp/api/okhttp.api
public fun onClosing (Lokhttp3/WebSocket;ILjava/lang/String;)V public fun onFailure (Lokhttp3/WebSocket;Ljava/lang/Throwable;Lokhttp3/Response;)V public fun onMessage (Lokhttp3/WebSocket;Ljava/lang/String;)V public fun onMessage (Lokhttp3/WebSocket;Lokio/ByteString;)V public fun onOpen (Lokhttp3/WebSocket;Lokhttp3/Response;)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/StaxLocation.java
String message = e.getMessage(); if (e instanceof XMLStreamException xe && xe.getLocation() != null) { int idx = message.indexOf("\nMessage: "); if (idx >= 0) { return message.substring(idx + "\nMessage: ".length()); } } return message; } public StaxLocation(javax.xml.stream.Location location) { this.location = location;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 2.3K bytes - Viewed (0)