the length of the mapped output, according to this table: L57: * L58: * ``` L59: * 0..63 : Length of the UTF-16 sequence that this range maps to. The offset is b2b3. L60: * 64..79 : Offset by a fixed negative offset. The bottom 4 bits of b1 are the top 4 bits of the offset. L61: * 80..95 : Offset by a fixed positive offset. The bottom 4 bits of b1 are the top 4 bits of the offset. L62: * 119 : Ignored. L63: * 120 : Valid. L64: * 121 : Disallowed L65: * 122 : Mapped inline to the sequence:...

indexes the quantile indexes, each of which must be in the inclusive range [0, q] for L188: * q-quantiles; the order of the indexes is unimportant, duplicates will be ignored, and the L189: * set will be snapshotted when this method is called L190: * @throws IllegalArgumentException if {@code indexes} is empty L191: */ L192: public ScaleAndIndexes indexes(int... indexes) { L193: return new ScaleAndIndexes(scale, indexes.clone()); L194: } L195: L196: /** L197: ...

java.lang.Double.isNaN; L21: L22:import com.google.common.annotations.GwtIncompatible; L23:import com.google.common.annotations.J2ktIncompatible; L24:import com.google.common.primitives.Doubles; L25: L26:/** L27: * A mutable object which accumulates paired double values (e.g. points on a plane) and tracks some L28: * basic statistics over all the values added so far. This class is not thread safe. L29: * L30: * @author Pete Gillin L31: * @since 20.0 L32: */ L33:@J2ktIncompatible L34:@GwtIncompatible...

private static final BelowAll INSTANCE = new BelowAll(); L125: L126: private BelowAll() { L127: /* L128: * No code ever sees this bogus value for `endpoint`: This class overrides both methods that L129: * use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation L130: * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut L131: * instance. L132: */ L133: super(""); L134: } L135: L136:...

write operations performed by other threads are noticed. For most L1196: * purposes, the "count" field, tracking the number of elements, serves as that volatile L1197: * variable ensuring visibility. This is convenient because this field needs to be read in many L1198: * read operations anyway: L1199: * L1200: * - All (unsynchronized) read operations must first read the "count" field, and should not L1201: * look at table entries if it is 0. L1202: * L1203: * - All (synchronized)...

new ByteProcessor<@Nullable Void>() { L159: boolean firstCall = true; L160: L161: @Override L162: public boolean processBytes(byte[] buf, int off, int len) throws IOException { L163: assertTrue("consume() called twice", firstCall); L164: firstCall = false; L165: return false; L166: } L167: L168: @Override L169: public @Nullable Void getResult() { L170: return null; L171: } L172: };...

non-reified type or has bounds, {@code forDependants} is used to do further resolution, which L318: * doesn't try to resolve any type variable on generic declarations that are already being L319: * resolved. L320: * L321: * <p>Should only be called and overridden by {@link #resolve(TypeVariable)}. L322: */ L323: Type resolveInternal(TypeVariable<?> var, TypeTable forDependants) { L324: Type type = map.get(new TypeVariableKey(var)); L325: if (type == null) { L326: Type[]...

/** L671: * nextItem holds on to item fields because once we claim that an element exists in hasNext(), L672: * we must return it in the following next() call even if it was in the process of being removed L673: * when hasNext() was called. L674: */ L675: private @Nullable E nextItem; L676: L677: /** L678: * Index of element returned by most recent call to next. Reset to -1 if this element is deleted L679: * by a call to remove. L680: */ L681: private int lastRet;...

val stream1 = connection.newStream(headerEntries("a", "apple"), true) L1838: val out1 = stream1.getSink().buffer() L1839: out1.write(ByteArray(Settings.DEFAULT_INITIAL_WINDOW_SIZE)) L1840: out1.flush() L1841: L1842: // Check that we've filled the window for both the stream and also the connection. L1843: assertThat(connection.writeBytesTotal) L1844: .isEqualTo(Settings.DEFAULT_INITIAL_WINDOW_SIZE.toLong()) L1845: assertThat(connection.writeBytesMaximum) L1846: .isEqual...

supported. When given an element that doesn't satisfy the predicate, the set's {@code L1009: * add()} and {@code addAll()} methods throw an {@link IllegalArgumentException}. When methods L1010: * such as {@code removeAll()} and {@code clear()} are called on the filtered set, only elements L1011: * that satisfy the filter will be removed from the underlying set. L1012: * L1013: * <p>The returned set isn't threadsafe or serializable, even if {@code unfiltered} is. L1014: * L1015: * <p>Many...