- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 120 for conceal (4.58 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
get().log("[ES] onFailure", Platform.INFO, t) events.add(Failure(t, response)) drainCancelQueue(eventSource) } private fun drainCancelQueue(eventSource: EventSource) { if (cancel) { cancel = false eventSource.cancel() } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
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/internal/ws/WebSocketHttpTest.kt
val server = serverListener.assertOpen() // Initiate a close on the client, which will schedule a hard cancel in 500 ms. val closeAtNanos = System.nanoTime() webSocket.close(1000, "goodbye", 500L) serverListener.assertClosing(1000, "goodbye") // Confirm that the hard cancel occurred after 500 ms. clientListener.assertFailure() val elapsedUntilFailure = System.nanoTime() - closeAtNanos
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/DispatcherTest.kt
assertThat(dispatcher.runningCalls()) .containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Cancel some calls. That doesn't impact running or queued. a2.cancel() a3.cancel() assertThat(dispatcher.runningCalls()) .containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Let the calls finish.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
manifests/charts/base/README.md
To install the chart with the release name `istio-base`: ```console kubectl create namespace istio-system helm install istio-base istio/base -n istio-system ``` ### Profiles Istio Helm charts have a concept of a `profile`, which is a bundled collection of value presets. These can be set with `--set profile=<profile>`.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 1.3K bytes - Viewed (0) -
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) -
okhttp/src/main/kotlin/okhttp3/Call.kt
*/ fun enqueue(responseCallback: Callback) /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */ fun isExecuted(): Boolean
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
docs/features/connections.md
* Don't start a new attempt until 250 ms after the most recent attempt was started. * Keep whichever TCP connection succeeds first and cancel all the others. * Race TCP only. Only attempt a TLS handshake on the winning TCP connection.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/apache/maven/maven/2.0/maven-2.0.pom
Plain Text - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 8.6K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public static final field INSTANCE Lmockwebserver3/SocketPolicy$StallSocketAtStart; } public abstract interface class mockwebserver3/Stream { public abstract fun cancel ()V public abstract fun getRequestBody ()Lokio/BufferedSource; public abstract fun getResponseBody ()Lokio/BufferedSink; } public abstract interface class mockwebserver3/StreamHandler {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.7K bytes - Viewed (0)