- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 127 for cancel0 (0.21 sec)
-
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/Cancel.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.launcher.daemon.protocol; public class Cancel extends Message {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 702 bytes - Viewed (0) -
src/database/sql/example_service_test.go
// This is a long SELECT. Use the request context as the base of // the context timeout, but give it some time to finish. If // the client cancels before the query is done the query will also // be canceled. ctx, cancel := context.WithTimeout(r.Context(), 60*time.Second) defer cancel() var names []string rows, err := db.QueryContext(ctx, "select p.name from people as p where p.active = true;") if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 28 20:21:26 UTC 2024 - 4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/errgroup/errgroup.go
// // The derived Context is canceled the first time a function passed to Go // returns a non-nil error or the first time Wait returns, whichever occurs // first. func WithContext(ctx context.Context) (*Group, context.Context) { ctx, cancel := withCancelCause(ctx) return &Group{cancel: cancel}, ctx } // Wait blocks until all function calls from the Go method have returned, then
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 3.3K bytes - Viewed (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 { } } }()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/cachevalue/cache_test.go
return time.Now(), slowCaller(ctx) }, ) ctx, cancel := context.WithCancel(context.Background()) cancel() // cancel context to test. _, err := cache.GetWithCtx(ctx) if !errors.Is(err, context.Canceled) { t.Fatalf("expected context.Canceled err, got %v", err) } ctx, cancel = context.WithCancel(context.Background()) defer cancel() t1, err := cache.GetWithCtx(ctx) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 2.7K 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 } } enum class ConnectState {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
} }.buffer() }, ) .build() var responseClosed = false var canceled = false var afterCallbackOnResponse: () -> Unit = {} override fun cancel() { canceled = true } override fun enqueue(responseCallback: Callback) { responseCallback.onResponse(this, response) afterCallbackOnResponse()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
ctx, cancel := context.WithCancel(ctx) target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, cancel: cancel, cancelCh: ctx.Done(), } return target, nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.7K bytes - Viewed (0) -
internal/event/target/webhook.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.5K bytes - Viewed (0) -
.github/workflows/upgrade-ci-cd.yaml
name: Upgrade old version tests on: pull_request: branches: - master # 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 }} runs-on: ${{ matrix.os }} strategy:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 729 bytes - Viewed (0)