Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 456 for consumer (0.04 sec)

  1. guava/src/com/google/common/eventbus/SubscriberRegistry.java

              checkArgument(
                  !parameterTypes[0].isPrimitive(),
                  "@Subscribe method %s's parameter is %s. "
                      + "Subscriber methods cannot accept primitives. "
                      + "Consider changing the parameter to %s.",
                  method,
                  parameterTypes[0].getName(),
                  Primitives.wrap(parameterTypes[0]).getSimpleName());
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  2. README.md

    > [!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
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/Files.java

        if (parent == null) {
          /*
           * The given directory is a filesystem root. All zero of its ancestors exist. This doesn't
           * mean that the root itself exists -- consider x:\ on a Windows machine without such a drive
           * -- or even that the caller can create it, but this method makes no such guarantees even for
           * non-root files.
           */
          return;
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Comparators.java

       * 1] < [1, 2] < [2]}.
       *
       * <p>Note that {@code Collections.reverseOrder(lexicographical(comparator))} is not equivalent to
       * {@code lexicographical(Collections.reverseOrder(comparator))} (consider how each would order
       * {@code [1]} and {@code [1, 1]}).
       */
      // Note: 90% of the time we don't add type parameters or wildcards that serve only to "tweak" the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common.go

    	}
    
    	inconsistent := 0
    	for i, meta := range partsMetadata {
    		if !meta.IsValid() {
    			// Since for majority of the cases erasure.Index matches with erasure.Distribution we can
    			// consider the offline disks as consistent.
    			continue
    		}
    		if !meta.Deleted {
    			if len(meta.Erasure.Distribution) != len(onlineDisks) {
    				// Erasure distribution seems to have lesser
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/QueuesTest.java

          // we indeed waited; a slow thread had enough time to interrupt us
        }
      }
    
      // same as above; uninterruptible version
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      private void assertUninterruptibleDrained(BlockingQueue<Object> q) {
        assertEquals(0, Queues.drainUninterruptibly(q, ImmutableList.of(), 0, 10, MILLISECONDS));
    
        // but does the wait actually occurs?
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  7. mvnw

      fi
      while IFS="=" read -r key value; do
        # Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' )
        safeValue=$(echo "$value" | tr -d '\r')
        case "$key" in wrapperUrl)
          wrapperUrl="$safeValue"
          break
          ;;
        esac
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Oct 14 22:24:15 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

        }
    
        /**
         * Determine optimal polling interval based on directory activity and failure count
         *
         * Current strategy is based on failure count. In the future, this could be enhanced to consider:
         * - Recent event frequency (successful notifications)
         * - Time since last successful notification
         * - Events per unit time for more adaptive behavior
         *
         * @param handle notification handle
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

       *     previously called
       * @since 11.0
       */
      @GwtIncompatible // To be supported
      @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
      public <K1 extends K, V1 extends V> CacheBuilder<K1, V1> weigher(
          Weigher<? super K1, ? super V1> weigher) {
        checkState(this.weigher == null);
        if (strictParsing) {
          checkState(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  10. docs/pt/docs/deployment/docker.md

    Mas isso também significa que, como o número de processos depende da CPU do contêiner em execução, a **quantidade de memória consumida** também dependerá disso.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 37.4K bytes
    - Viewed (0)
Back to top