L31:@ElementTypesAreNonnullByDefault L32:abstract class AbstractStreamingHasher extends AbstractHasher { L33: /** Buffer via which we pass data to the hash algorithm (the implementor) */ L34: private final ByteBuffer buffer; L35: L36: /** Number of bytes to be filled before process() invocation(s). */ L37: private final int bufferSize; L38: L39: /** Number of bytes processed per process() invocation. */ L40: private final int chunkSize; L41: L42: /** L43: * Constructor for use by subclasses. This hasher...

manage their listeners. An L28: * instance contains a list of listeners, each with an associated {@code Executor}, and guarantees L29: * that every {@code Runnable} that is {@linkplain #add added} will be executed after {@link L30: * #execute()} is called. Any {@code Runnable} added after the call to {@code execute} is still L31: * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the L32: * order that they are added. L33: * L34: * <p>Exceptions thrown by a listener...

or values are L353: * not allowed, and will cause {@link #build} to fail. L354: */ L355: @CanIgnoreReturnValue L356: @Override L357: public Builder<K, V> put(K key, V value) { L358: super.put(key, value); L359: return this; L360: } L361: L362: /** L363: * Adds the given {@code entry} to the bimap. Duplicate keys or values are not allowed, and will L364: * cause {@link #build} to fail. L365: * L366: * @since 19.0 L367: */ L368: @CanIgnoreReturnValue...

RunnableExecutorPair newHead = new RunnableExecutorPair(runnable, executor); L635: RunnableExecutorPair oldHead; L636: do { L637: oldHead = head; L638: if (oldHead == null) { L639: // If runnables == null then execute() has been called so we should just execute our L640: // listener immediately. L641: newHead.execute(); L642: return; L643: } L644: // Try to make newHead the new head of the stack at runnables. L645: newHead.next = oldHead;...

8 bytes L63: */ L64: static long load64Safely(byte[] input, int offset, int length) { L65: long result = 0; L66: // Due to the way we shift, we can stop iterating once we've run out of data, the rest L67: // of the result already being filled with zeros. L68: L69: // This loop is critical to performance, so please check HashBenchmark if altering it. L70: int limit = min(length, 8); L71: for (int i = 0; i < limit; i++) { L72: // Shift value left while iterating logically through...

given an element that L292: * doesn't satisfy the predicate, the multiset's {@code add()} and {@code addAll()} methods throw L293: * an {@link IllegalArgumentException}. When methods such as {@code removeAll()} and {@code L294: * clear()} are called on the filtered multiset, only elements that satisfy the filter will be L295: * removed from the underlying multiset. L296: * L297: * <p>The returned multiset isn't threadsafe or serializable, even if {@code unfiltered} is. L298: * L299: ...

given an element that L296: * doesn't satisfy the predicate, the multiset's {@code add()} and {@code addAll()} methods throw L297: * an {@link IllegalArgumentException}. When methods such as {@code removeAll()} and {@code L298: * clear()} are called on the filtered multiset, only elements that satisfy the filter will be L299: * removed from the underlying multiset. L300: * L301: * <p>The returned multiset isn't threadsafe or serializable, even if {@code unfiltered} is. L302: * L303: ...

L31:@ElementTypesAreNonnullByDefault L32:abstract class AbstractStreamingHasher extends AbstractHasher { L33: /** Buffer via which we pass data to the hash algorithm (the implementor) */ L34: private final ByteBuffer buffer; L35: L36: /** Number of bytes to be filled before process() invocation(s). */ L37: private final int bufferSize; L38: L39: /** Number of bytes processed per process() invocation. */ L40: private final int chunkSize; L41: L42: /** L43: * Constructor for use by subclasses. This hasher...

extends @Nullable Object, V extends @Nullable Object> L56: extends ForwardingMap<K, V> implements BiMap<K, V>, Serializable { L57: L58: @SuppressWarnings("nullness:initialization.field.uninitialized") // For J2KT (lateinit) L59: private transient Map<K, V> delegate; L60: L61: @SuppressWarnings("nullness:initialization.field.uninitialized") // For J2KT (lateinit) L62: @RetainedWith L63: transient AbstractBiMap<V, K> inverse; L64: L65: /** Package-private constructor for creating a map-backed bimap....

FilterChain chain) { L55: calledFirst.set(true); L56: assertFalse(called.get()); L57: QueryBuilder builder = chain.execute(context, query, boost); L58: assertTrue(called.get()); L59: return builder; L60: } L61: }); L62: queryBuilder = queryProcessor.execute(context, query, 1.0f); L63: assertTrue(called.get()); L64: assertTrue(calledFirst.get()); L65: assertEquals(BoolQueryBuilder.class,...