Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 351 for consumer (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/io/BaseEncoding.java

     *
     * @author Louis Wasserman
     * @since 14.0
     */
    @GwtCompatible
    public abstract class BaseEncoding {
      // TODO(lowasser): consider making encodeTo(Appendable, byte[], int, int) public.
    
      BaseEncoding() {}
    
      /**
       * Exception indicating invalid base-encoded input encountered while decoding.
       *
       * @author Louis Wasserman
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Oct 06 14:51:47 GMT 2025
    - 41.7K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

      // 'inputFuture'. That field is non-final and non-volatile. There are 2 places where the
      // 'inputFuture' field is read and where we will have to consider visibility of the write
      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

     * is not guaranteed to traverse the elements of the MonitorBasedPriorityBlockingQueue in
     * any particular order. If you need ordered traversal, consider using {@code
     * Arrays.sort(pq.toArray())}. Also, method {@code drainTo} can be used to remove some or
     * all elements in priority order and place them in another collection.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  5. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * line, then it means that the area (time) is increased, thus storedPermits are more costly than
       * fresh permits, thus the RateLimiter becomes /slower/ after a period of underutilization.
       *
       * Last, but not least: consider a RateLimiter with rate of 1 permit per second, currently
       * completely unused, and an expensive acquire(100) request comes. It would be nonsensical to just
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  6. docs/en/docs/alternatives.md

    Then APIStar stopped to exist as a server and Starlette was created, and was a new better foundation for such a system. That was the final inspiration to build **FastAPI**.
    
    I consider **FastAPI** a "spiritual successor" to APIStar, while improving and increasing the features, typing system, and other parts, based on the learnings from all these previous tools.
    
    ///
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  7. cmd/testdata/xl-meta-merge.zip

    browser to <http://127.0.0.1:9000> to ensure your server has started successfully. > NOTE: MinIO runs console on random port by default, if you wish to choose a specific port use `--console-address` to pick a specific interface and port. ### Things to consider MinIO redirects browser access requests to the configured server port (i.e. `127.0.0.1:9000`) to the configured Console port. MinIO uses the hostname or IP address specified in the request when building the redirect URL. The URL and port *must* be...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 30.2K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

       * cache afterward).
       */
      @GwtIncompatible // QueuingRemovalListener
    
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testRemovalNotification_clear_basher() throws InterruptedException {
        // If a clear() happens close to the end of computation, one of two things should happen:
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

     * who can't use Java 8, or who want an API more focused than {@code CompletableFuture}. (If you
     * need to adapt between {@code CompletableFuture} and {@code ListenableFuture}, consider <a
     * href="https://github.com/lukas-krecan/future-converter">Future Converter</a>.)
     *
     * <h3>Extension</h3>
     *
     * If you want a class like {@code FluentFuture} but with extra methods, we recommend declaring your
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  10. cmd/bucket-lifecycle.go

    		// transitioned tier lies untouched and still accessible
    		opts.Transition.ExpireRestored = true
    		_, err := objectAPI.DeleteObject(ctx, oi.Bucket, oi.Name, opts)
    		if err == nil {
    			// TODO consider including expiry of restored object to events we
    			// notify.
    			auditLogLifecycle(ctx, *oi, ILMExpiry, tags, traceFn)
    		}
    		return err
    	}
    
    	// Delete remote object from warm-tier
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
Back to Top