- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for canceling (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not * the other streams sharing its connection. But if the TLS handshake is still in progress then * canceling may break the entire connection. */ class RealCall( val client: OkHttpClient,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
internal/grid/stream.go
type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
} // LoadEncryptionConfig parses and validates the encryption config specified by filepath. // It may launch multiple go routines whose lifecycle is controlled by ctx. // In case of an error, the caller is responsible for canceling ctx to clean up any go routines that may have been launched. // If reload is true, or KMS v2 plugins are used with no KMS v1 plugins, the returned slice of health checkers will always be of length 1.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
}, executor); } } /** * Returns a {@code ListenableFuture} whose result is set from the supplied future when it * completes. Cancelling the supplied future will also cancel the returned future, but cancelling * the returned future will have no effect on the supplied future. * * @since 15.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* UnsupportedOperationException. * * <p>The implementation deviates from the {@code ExecutorService} specification with regards to * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* UnsupportedOperationException. * * <p>The implementation deviates from the {@code ExecutorService} specification with regards to * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
}, executor); } } /** * Returns a {@code ListenableFuture} whose result is set from the supplied future when it * completes. Cancelling the supplied future will also cancel the returned future, but cancelling * the returned future will have no effect on the supplied future. * * @since 15.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
src/context/context.go
// context's Done channel is closed when the returned cancel function is called // or when the parent context's Done channel is closed, whichever happens first. // // Canceling this context releases resources associated with it, so code should // call cancel as soon as the operations running in this [Context] complete. func WithCancel(parent Context) (ctx Context, cancel CancelFunc) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
internal/grid/muxserver.go
for { select { case <-m.ctx.Done(): return case <-t.C: last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0)) if last > 4*m.clientPingInterval { gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last)) m.close() return } } } } // checkSeq will check if sequence number is correct and increment it by 1.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/context/x_test.go
} if got := Cause(ccc); got != Canceled { t.Errorf("after CancelCauseFunc Cause(ccc) = %v, want %v", got, Canceled) } // Test that if we associate a custom context with a child, // then canceling the custom context cancels the child. ccc = &customCauseContext{ done: make(chan struct{}), } ctx, cancelFunc := WithCancel(ccc) ccc.setCancelChild(cancelFunc) ccc.cancel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0)