Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,192 for call$ (0.03 sec)

  1. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     * Tasks execute with the same happens-before order that the function calls to {@link #submit} and
     * {@link #submitAsync} that submitted those tasks had.
     *
     * <p>This class has limited support for cancellation and other "early completions":
     *
     * <ul>
     *   <li>While calls to {@code submit} and {@code submitAsync} return a {@code Future} that can be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    	// Use a separate client to avoid recursive calls.
    	healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    	restClient.HealthCheckFn = func() bool {
    		ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout)
    		defer cancel()
    		respBody, err := healthClient.Call(ctx, peerRESTMethodHealth, nil, nil, -1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

                .write(ByteArray(responseBodySize)),
            )
            .throttleBody(64 * 1024, 125, MILLISECONDS) // 500 Kbps
            .build(),
        )
        val call = client.newCall(Request(server.url("/")))
        val response = call.execute()
        cancelLater(call, 500)
        val responseBody = response.body.byteStream()
        val buffer = ByteArray(1024)
        assertFailsWith<IOException> {
          while (responseBody.read(buffer) != -1) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  4. docs/recipes.md

            final Call call = client.newCall(request);
    
            // Schedule a job to cancel the call in 1 second.
            executor.schedule(new Runnable() {
              @Override public void run() {
                System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f);
                call.cancel();
                System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Feb 18 08:52:22 UTC 2022
    - 40.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/bsbhv/BsFailureUrlBhv.java

        public int[] batchInsert(List<FailureUrl> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<FailureUrl> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/bsbhv/BsRelatedQueryBhv.java

        public int[] batchInsert(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/log/bsbhv/BsUserInfoBhv.java

        public int[] batchInsert(List<UserInfo> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<UserInfo> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
        public int[] batchUpdate(List<UserInfo> list) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

         *     {@link #whenAllComplete(Iterable)} or {@link #whenAllComplete(Iterable)}
         * @throws IllegalStateException if called outside of a call to {@link
         *     CombiningCallable#call(DeferredCloser, Peeker)} or {@link
         *     AsyncCombiningCallable#call(DeferredCloser, Peeker)}
         */
        @ParametricNullness
        public final <D extends @Nullable Object> D getDone(ClosingFuture<D> closingFuture)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * using a lock, however it is dangerous to dispatch listeners while holding a lock because they
     * might run on the {@code directExecutor()} or be otherwise re-entrant (call back into your
     * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
     * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/es/config/bsbhv/BsDataConfigBhv.java

        public int[] batchInsert(List<DataConfig> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<DataConfig> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top