- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for conceal (0.23 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val response1 = call1.execute() waitForDataFrames(Http2Connection.OKHTTP_CLIENT_WINDOW_SIZE) // Cancel the call and discard what we've buffered for the response body. This should free up // the connection flow-control window so new requests can proceed. call1.cancel() assertThat( response1.body.source().discard(1, TimeUnit.SECONDS), "Call should not have completed successfully.",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-GpVkmM8vF2vQUkj2LvZmD35JxeJOLCwJ9cUkugyk2nuhbv3+mJvpLYYt+0+USMxE+oj+ey/lJEnhZw75x/OMcQ== concat-map@0.0.1: version "0.0.1" resolved "https://registry.yarnpkg.com/concat-map/-/concat-map-0.0.1.tgz#d8a96bd77fd68df7793a73036a3ba0d5405d477b" integrity sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg== connect@^3.7.0:
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
) val call = client.newCall( Request.Builder() .url(server.url("/")) .build(), ) call.cancel() call.cancel() assertThat(listener.recordedEventTypes()).containsExactly("Canceled") } private fun assertSuccessfulEventOrder(responseMatcher: Matcher<Response?>?) { val call = client.newCall( Request.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
internal var connectTimeout = 10_000 internal var readTimeout = 10_000 internal var writeTimeout = 10_000 internal var pingInterval = 0 internal var webSocketCloseTimeout = RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS.toInt() internal var minWebSocketMessageToCompress = RealWebSocket.DEFAULT_MINIMUM_DEFLATE_SIZE internal var routeDatabase: RouteDatabase? = null internal var taskRunner: TaskRunner? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final class okhttp3/CacheControl$Companion { public final fun parse (Lokhttp3/Headers;)Lokhttp3/CacheControl; } public abstract interface class okhttp3/Call : java/lang/Cloneable { public abstract fun cancel ()V public abstract fun clone ()Lokhttp3/Call; public abstract fun enqueue (Lokhttp3/Callback;)V public abstract fun execute ()Lokhttp3/Response; public abstract fun isCanceled ()Z public abstract fun isExecuted ()Z
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
// Play it back. connect(peer, PushObserver.CANCEL, Http2Connection.Listener.REFUSE_INCOMING_STREAMS) // Verify the peer received what was expected. val rstStream = peer.takeFrame() assertThat(rstStream.type).isEqualTo(Http2.TYPE_RST_STREAM) assertThat(rstStream.streamId).isEqualTo(2) assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)