- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for conceal (0.21 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/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) -
okhttp-coroutines/src/test/kotlin/okhttp3/SuspendCallTest.kt
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
return null } /** * Cancel all calls currently enqueued or executing. Includes calls executed both * [synchronously][Call.execute] and [asynchronously][Call.enqueue]. */ fun cancelAll() { this.withLock { for (call in readyAsyncCalls) { call.call.cancel() } for (call in runningAsyncCalls) { call.call.cancel() } for (call in runningSyncCalls) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/CancelCall.java
.build(); final long startNanos = System.nanoTime(); final Call call = client.newCall(request); // Schedule a job to cancel the call in 1 second. executor.schedule(() -> { System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f); call.cancel(); System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f); }, 1, TimeUnit.SECONDS);
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 12 03:31:36 GMT 2019 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication. * * It is possible to cancel the finding process by canceling its call. * * Implementations of this interface are not thread-safe. Each instance is thread-confined to the * thread executing the call. */ interface RoutePlanner {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
connectState = ConnectState.TLS_CONNECTED ConnectResult(this) } } } override fun handleSuccess() = connection override fun cancel() { events += "plan $id cancel" canceled = true } override fun retry(): FakePlan? { check(!retryTaken) retryTaken = true return retry } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
apply { actions += { stream -> if (!stream.requestBody.exhausted()) throw AssertionError("expected exhausted") } } fun cancelStream() = apply { actions += { stream -> stream.cancel() } } fun requestIOException() = apply { actions += { stream -> try { stream.requestBody.exhausted() throw AssertionError("expected IOException")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
last: Boolean, ): Boolean /** Indicates the reason why this stream was canceled. */ fun onReset( streamId: Int, errorCode: ErrorCode, ) companion object { @JvmField val CANCEL: PushObserver = PushObserverCancel() private class PushObserverCancel : PushObserver { override fun onRequest( streamId: Int, requestHeaders: List<Header>, ): Boolean {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0)