Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 2,436 for Call (0.02 seconds)

  1. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * given executor at the first call to {@code addListener}. The task must be started by the
       * executor promptly, or else the returned {@code ListenableFuture} may fail to work. The task's
       * execution consists of blocking until the input future is {@linkplain Future#isDone() done}, so
       * each call to this method may claim and hold a thread for an arbitrary length of time. Use of
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/AbstractSequentialIterator.java

      }
    
      /**
       * Returns the element that follows {@code previous}, or returns {@code null} if no elements
       * remain. This method is invoked during each call to {@link #next()} in order to compute the
       * result of a <i>future</i> call to {@code next()}.
       */
      protected abstract @Nullable T computeNext(T previous);
    
      @Override
      public final boolean hasNext() {
        return nextOrNull != null;
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link
     * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any
     * other {@code Future}, be {@linkplain #cancel cancelled}.
     *
     * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  4. cmd/bucket-encryption-handlers.go

    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketSSEConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	//
    	// We encode the xml bytes as base64 to ensure there are no encoding
    	// errors.
    	cfgStr := base64.StdEncoding.EncodeToString(configData)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/collect/QueuesTest.java

            threadPool.submit(
                new Callable<@Nullable Void>() {
                  @Override
                  public @Nullable Void call() throws InterruptedException {
                    new Producer(q, 50).call();
                    new Interrupter(mainThread).run();
                    new Producer(q, 50).call();
                    return null;
                  }
                });
        List<Object> buf = new ArrayList<>();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  6. docs/changelogs/changelog_4x.md

    ## Version 4.0.1
    
    _2019-07-10_
    
     *  Fix: Tolerate null-hostile lists in public API. Lists created with `List.of(...)` don't like it
        when you call `contains(null)` on them!
     *  Fix: Retain binary-compatibility in `okhttp3.internal.HttpHeaders.hasBody()`. Some unscrupulous
        coders call this and we don't want their users to suffer.
    
    
    ## Version 4.0.0
    
    _2019-06-26_
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/SettableFuture.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link
     * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any
     * other {@code Future}, be {@linkplain #cancel cancelled}.
     *
     * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     *
     * <p>{@code RuntimeException}s thrown by tasks are simply logged and the executor keeps trucking.
     * If an {@code Error} is thrown, the error will propagate and execution will stop until it is
     * restarted by a call to {@link #execute}.
     */
    @J2ktIncompatible
    @GwtIncompatible
    final class SequentialExecutor implements Executor {
      private static final LazyLogger log = new LazyLogger(SequentialExecutor.class);
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     *
     * <p>{@code RuntimeException}s thrown by tasks are simply logged and the executor keeps trucking.
     * If an {@code Error} is thrown, the error will propagate and execution will stop until it is
     * restarted by a call to {@link #execute}.
     */
    @J2ktIncompatible
    @GwtIncompatible
    final class SequentialExecutor implements Executor {
      private static final LazyLogger log = new LazyLogger(SequentialExecutor.class);
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        /**
         * It is implicitly assumed that all the services are NEW and that they will all remain NEW
         * until all the Listeners are installed and {@link #markReady()} is called. It is our caller's
         * responsibility to only call {@link #markReady()} if all services were new at the time this
         * method was called and when all the listeners were installed.
         */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
Back to Top