Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 442 for consumer (0.05 seconds)

  1. 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;
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/base/internal/Finalizer.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * Thread that finalizes referents. All references should implement {@code
     * com.google.common.base.FinalizableReference}.
     *
     * <p>While this class is public, we consider it to be *internal* and not part of our published API.
     * It is public so we can access it reflectively across class loaders in secure environments.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 9.3K bytes
    - Click Count (0)
  3. src/bytes/buffer.go

    }
    
    // ReadRune reads and returns the next UTF-8-encoded
    // Unicode code point from the buffer.
    // If no bytes are available, the error returned is io.EOF.
    // If the bytes are an erroneous UTF-8 encoding, it
    // consumes one byte and returns U+FFFD, 1.
    func (b *Buffer) ReadRune() (r rune, size int, err error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, 0, io.EOF
    	}
    	c := b.buf[b.off]
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  4. android/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());
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java

            CollectionSize.ANY);
        return MapTestSuiteBuilder.using(generator)
            .named(name)
            .withFeatures(featuresList)
            .createTestSuite();
      }
    
      // TODO: consider being null-hostile in these tests
    
      private static Test testsForHashMapNullKeysForbidden() {
        return wrappedHashMapTests(
            new WrappedHashMapGenerator() {
              @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu May 22 16:18:11 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        result.timer = scheduledExecutor.schedule(fire, time, unit);
        delegate.addListener(fire, directExecutor());
        return result;
      }
    
      /*
       * Memory visibility of these fields. There are two cases to consider.
       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/primitives/Ints.java

       *     such index exists.
       */
      public static int indexOf(int[] array, int target) {
        return indexOf(array, target, 0, array.length);
      }
    
      // TODO(kevinb): consider making this public
      private static int indexOf(int[] array, int target, int start, int end) {
        for (int i = start; i < end; i++) {
          if (array[i] == target) {
            return i;
          }
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 22 18:14:49 GMT 2025
    - 31.3K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            }
          }
        }
      }
    
      @SuppressWarnings({
        "Interruption", // We are restoring an interrupt on this thread.
        "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait.
      })
      private void waitForInterrupt(Thread currentThread) {
        /*
         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 10K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
     * calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}.
     *
     * <p><b>Java 21+ users:</b> consider using the {@code Thread.Builder} interface instead. E.g.,
     * instead of {@code new ThreadFactoryBuilder().setPriority(priority).setDaemon(false).build()}, use
     * {@code Thread.ofPlatform().priority(priority).daemon(false).factory()}.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:35:26 GMT 2025
    - 9K bytes
    - Click Count (0)
  10. guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

    @SuppressWarnings("JUnit4ClassUsedInJUnit3")
    public abstract class AbstractMultisetSetCountTester<E> extends AbstractMultisetTester<E> {
      /*
       * TODO: consider adding MultisetFeatures.SUPPORTS_SET_COUNT. Currently we
       * assume that using setCount() to increase the count is permitted iff add()
       * is permitted and similarly for decrease/remove(). We assume that a
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 13K bytes
    - Click Count (0)
Back to Top