- Sort Score
- Num 10 results
- Language All
Results 291 - 300 of 442 for consumer (0.05 seconds)
-
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) -
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) -
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) -
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) -
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() { @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu May 22 16:18:11 GMT 2025 - 11.8K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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 aCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13K bytes - Click Count (0)