Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 300 for Cancel (0.04 sec)

  1. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(CancellationException.class, () -> getUnchecked(future));
      }
    
      public void testGetUnchecked_executionExceptionChecked() {
        UncheckedExecutionException expected =
            assertThrows(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

                assertFailsWith<IOException> {
                  response.trailers()
                }
              assertThat(exception.message).isIn(
                "Socket closed", // HTTP/1.1
                "stream was reset: CANCEL", // HTTP/2
              )
            }
          assertThat(trailersDelay).isGreaterThan(250.milliseconds)
          assertThat(trailersDelay).isLessThan(750.milliseconds)
        }
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 18K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/witness/WitnessClient.java

            // Stop all async notification tasks first
            List<CompletableFuture<Void>> taskFutures = new ArrayList<>(asyncNotifyTasks.values());
            for (CompletableFuture<Void> task : taskFutures) {
                task.cancel(true);
            }
            asyncNotifyTasks.clear();
    
            // Unregister all active registrations
            List<CompletableFuture<Void>> unregisterFutures = new ArrayList<>();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/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 = true
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/timer/TimeoutTask.java

         *
         * @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.
         *
         * @return whether the task is stopped
         */
        public boolean isStopped() {
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  6. tests/prepared_stmt_test.go

    	if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok {
    		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
    	defer cancel()
    	txCtx := tx.WithContext(ctx)
    
    	user := *GetUser("prepared_stmt", Config{})
    
    	txCtx.Create(&user)
    
    	var result1 User
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

            throw IllegalStateException(
              "Cannot stream a request body without chunked encoding or a known content length!",
            )
        }
    
      override fun cancel() {
        carrier.cancel()
      }
    
      /**
       * Prepares the HTTP headers and sends them to the server.
       *
       * For streaming requests with a body, headers must be prepared **before** the output stream has
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  8. 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.
         */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

        return new TrustedListenableFutureTask<>(callable(runnable, result));
      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       *
       * <p>{@code volatile} is required for j2objc transpiling:
       * https://developers.google.com/j2objc/guides/j2objc-memory-model#atomicity
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  10. .github/workflows/iam-integrations.yaml

    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:
      iam-matrix-test:
        name: "[Go=${{ matrix.go-version }}|ldap=${{ matrix.ldap }}|etcd=${{ matrix.etcd }}|openid=${{ matrix.openid }}]"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.3K bytes
    - Viewed (0)
Back to top