- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 392 for canceled (0.07 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = tcpConnectThrowable) } canceled -> { events += "plan $id TCP connect canceled" ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled")) } connectTcpNextPlan != null -> { events += "plan $id needs follow-up"
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
} } catch (e: Exception) { val exception = when { canceled -> IOException("canceled", e) else -> e } listener.onFailure(this, exception, response) return } if (canceled) { listener.onFailure(this, IOException("canceled"), response) } else { listener.onClosed(this) } } }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Oct 03 07:51:20 GMT 2025 - 3.2K bytes - Click Count (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
return permanent; } /** * Returns whether the task has been canceled. * * @return whether the task has been canceled */ public boolean isCanceled() { return status == CANCELED; } /** * Cancels the task. */ public void cancel() { status = CANCELED; } /** * Returns whether the task is stopped. *Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 2.7K bytes - Click Count (0) -
internal/grid/stream.go
// Results returns the results from the remote server one by one. // If any error is returned by the callback, the stream will be canceled. // If the context is canceled, the stream will be canceled. func (s *Stream) Results(next func(b []byte) error) (err error) { done := false defer func() { if s.cancel != nil { s.cancel(err) } if !done { // Drain channel. for range s.responses { } } }()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jun 07 15:51:52 GMT 2024 - 3.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
taskFaker.advanceUntil(500.ms) assertEvents( "take plan 2", "plan 0 cancel", "plan 1 cancel", ) taskFaker.advanceUntil(510.ms) assertEvents( "plan 1 TCP connect canceled", ) taskFaker.advanceUntil(520.ms) assertEvents( "plan 0 TCP connect canceled", ) } @Test fun takeMultipleConnections() {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 20.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
stream = http2Connection.newStream(requestHeaders, hasRequestBody) // We may have been asked to cancel while creating the new stream and sending the request // headers, but there was still no stream to close. if (canceled) { stream!!.closeLater(ErrorCode.CANCEL) throw IOException("Canceled") } stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 7K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/EncryptInvoker.java
public static final int OK = 0; // OK public static final int ERROR = 1; // "generic" error public static final int BAD_OPERATION = 2; // bad user input or alike public static final int CANCELED = 3; // user canceled public EncryptInvoker(Lookup protoLookup, @Nullable Consumer<LookupContext> contextConsumer) { super(protoLookup, contextConsumer); } @OverrideCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 4.5K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/UpgradeInvoker.java
public static final int OK = 0; // OK public static final int ERROR = 1; // "generic" error public static final int BAD_OPERATION = 2; // bad user input or alike public static final int CANCELED = 3; // user canceled public UpgradeInvoker(Lookup protoLookup, @Nullable Consumer<LookupContext> contextConsumer) { super(protoLookup, contextConsumer); } @OverrideCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 4.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
*/ fun cancel() fun interface Factory { /** * Creates a new web socket and immediately returns it. Creating a web socket initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must either close or cancel the returned web socket when it is no longer * in use.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:45:14 GMT 2026 - 6.1K bytes - Click Count (0)