- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 213 for cancel (0.21 sec)
-
fastapi/security/api_key.py
] = None, auto_error: Annotated[ bool, Doc( """ By default, if the query parameter is not provided, `APIKeyQuery` will automatically cancel the request and send the client an error. If `auto_error` is set to `False`, when the query parameter is not available, instead of erroring out, the dependency result will be
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 23 22:29:18 GMT 2024 - 9.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
} /** * キャンセルされているかどうかを返します。 * * @return キャンセルされているか */ public boolean isCanceled() { return status == CANCELED; } /** * キャンセルします。 */ public void cancel() { status = CANCELED; } /** * 止まっているかどうか返します。 * * @return 止まっているかどうか */ public boolean isStopped() { return status == STOPPED;
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
@ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
override fun request(): Request = error("unexpected") override fun execute(): Response = error("unexpected") override fun enqueue(responseCallback: Callback): Unit = error("unexpected") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected") override fun isCanceled(): Boolean = error("unexpected") override fun timeout(): Timeout = error("unexpected")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 1.1K bytes - Viewed (0) -
cmd/test-utils_test.go
setObjectLayer(newObjectLayerFn()) cancel() removeRoots(fsDirs) } } // ExecObjectLayerTestWithDirs - executes object layer tests. // Creates single node and Erasure ObjectLayer instance and runs test for both the layers. func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() if localMetacacheMgr != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
.github/workflows/go.yml
name: Functional Tests on: pull_request: branches: - master - next # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: build: name: Go ${{ matrix.go-version }} on ${{ matrix.os }} - healing runs-on: ${{ matrix.os }} strategy:
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 23:44:49 GMT 2024 - 1.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
// transport is already down. return info, errDiskNotFound } // if 'NoOp' we do not cache the value. if opts.NoOp { ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() opts.DiskID = *client.diskID.Load() infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &opts) if err != nil { return info, toStorageErr(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/license-update.go
duration = time.Second } time.Sleep(duration) } }() } func licenceUpdaterLoop(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() licenseUpdateTimer := time.NewTimer(licUpdateCycle) defer licenseUpdateTimer.Stop() for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
.github/workflows/go-cross.yml
name: Crosscompile on: pull_request: branches: - master - next # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: build: name: Build Tests with Go ${{ matrix.go-version }} on ${{ matrix.os }} runs-on: ${{ matrix.os }}
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 09:25:58 GMT 2024 - 970 bytes - Viewed (0) -
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)