- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for websockets (0.2 sec)
-
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) -
samples/slack/src/main/java/okhttp3/slack/SlackApi.java
import com.squareup.moshi.JsonAdapter; import com.squareup.moshi.Moshi; import com.squareup.moshi.ToJson; import java.io.IOException; import okhttp3.Call; import okhttp3.HttpUrl; import okhttp3.WebSocket; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import okhttp3.WebSocketListener; import okio.ByteString; /**
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Jul 06 19:30:55 GMT 2018 - 4.4K bytes - Viewed (1) -
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) -
docs/changelogs/changelog_2x.md
causing some applications to crash when connections were reused. * Fix: `OkApacheClient` now allows an empty `PUT` and `POST`. * Fix: Websockets no longer rebuffer socket streams. * Fix: Websockets are now better at handling close frames. * Fix: Content type matching is now case insensitive. * Fix: `Vary` headers are not lost with `android.net.http.HttpResponseCache`.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0) -
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) -
samples/slack/src/main/java/okhttp3/slack/RtmSession.java
@Override public void onMessage(WebSocket webSocket, String text) { System.out.println("onMessage: " + text); } @Override public void onClosing(WebSocket webSocket, int code, String reason) { webSocket.close(1000, null); System.out.println("onClose (" + code + "): " + reason); } @Override public void onFailure(WebSocket webSocket, Throwable t, Response response) {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Nov 19 20:16:58 GMT 2016 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordedResponse.kt
import java.util.Date /** * A received response or failure recorded by the response recorder. */ class RecordedResponse( @JvmField val request: Request, val response: Response?, val webSocket: WebSocket?, val body: String?, val failure: IOException?, ) { fun assertRequestUrl(url: HttpUrl) = apply { assertThat(request.url).isEqualTo(url) } fun assertRequestMethod(method: String) =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
minimumDeflateSize = 0L, webSocketCloseTimeout = RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS, ) val name = "MockWebServer WebSocket ${request.path!!}" webSocket.initReaderAndWriter(name, streams) try { webSocket.loopReader(fancyResponse) // Even if messages are no longer being read we need to wait for the connection close signal. connectionClose.await()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/api/okhttp.api
} public abstract class okhttp3/WebSocketListener { public fun <init> ()V public fun onClosed (Lokhttp3/WebSocket;ILjava/lang/String;)V 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
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)