- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for websocketjs (0.16 sec)
-
docs/changelogs/changelog_4x.md
[fun_interface]: https://kotlinlang.org/docs/reference/fun-interfaces.html [iana_websocket]: https://www.iana.org/assignments/websocket/websocket.txt [jetty_8_252]: https://webtide.com/jetty-alpn-java-8u252/ [kotlin_1_3_71]: https://github.com/JetBrains/kotlin/releases/tag/v1.3.71
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
@Suppress("UNCHECKED_CAST") // E is either IOException or IOException? return e as E } /** * Stops applying the timeout before the call is entirely complete. This is used for WebSockets * and duplex calls where the timeout only applies to the initial setup. */ fun timeoutEarlyExit() { check(!timeoutEarlyExit) timeoutEarlyExit = true timeout.exit() } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
webSockets.add(client.newWebSocket(request, clientListener)) attempts.countDown() } } } clientListener.setNextEventDelegate(reconnectOnFailure) webSockets.add(client.newWebSocket(request, clientListener)) attempts.await() synchronized(webSockets) { for (webSocket in webSockets) { webSocket.cancel() } }
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/internal/ws/WebSocketRecorder.kt
webSocket: WebSocket, code: Int, reason: String, ) { Platform.get().log("[WS $name] onClosed $code", Platform.INFO, null) val delegate = delegate if (delegate != null) { this.delegate = null delegate.onClosed(webSocket, code, reason) } else { events.add(Closed(code, reason)) } } override fun onFailure( webSocket: WebSocket, t: Throwable,
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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits=15 * Sec-WebSocket-Extensions: permessage-deflate; client_no_context_takeover * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits="15" * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits=15 * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
*/ fun webSocketUpgrade(listener: WebSocketListener) = apply { status = "HTTP/1.1 101 Switching Protocols" setHeader("Connection", "Upgrade") setHeader("Upgrade", "websocket") webSocketListener = listener } /** * Configures this response to be served as a response to an HTTP CONNECT request, either for
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() server.webSocket!!.tearDown() client.webSocket!!.tearDown() taskFaker.close() } @Test fun close() { client.webSocket!!.close(1000, "Hello!") // This will trigger a close response. assertThat(server.processNextFrame()).isFalse() server.listener.assertClosing(1000, "Hello!") server.webSocket!!.finishReader() server.webSocket!!.close(1000, "Goodbye!")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersRequestTest.kt
} @Test fun http2HeadersListDropsForbiddenHeadersHttp2() { val request = Request.Builder() .url("http://square.com/") .header("Connection", "upgrade") .header("Upgrade", "websocket") .header("Host", "square.com") .header("TE", "gzip") .build() val expected = headerEntries( ":method", "GET", ":path", "/",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) { webSocket.send("Hello..."); webSocket.send("...World!"); webSocket.send(ByteString.decodeHex("deadbeef")); webSocket.close(1000, "Goodbye, World!"); } @Override public void onMessage(WebSocket webSocket, String text) { System.out.println("MESSAGE: " + text); }
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
* messages. */ open fun onOpen( webSocket: WebSocket, response: Response, ) { } /** Invoked when a text (type `0x1`) message has been received. */ open fun onMessage( webSocket: WebSocket, text: String, ) { } /** Invoked when a binary (type `0x2`) message has been received. */ open fun onMessage( webSocket: WebSocket, bytes: ByteString, ) { } /**
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)