readMoreChars(); L182: } L183: } else if (result.isError()) { L184: // Only reach here if a CharsetEncoder with non-REPLACE settings is used. L185: result.throwException(); L186: return 0; // Not called. L187: } L188: } L189: } L190: } L191: L192: /** Returns a new CharBuffer identical to buf, except twice the capacity. */ L193: private static CharBuffer grow(CharBuffer buf) { L194: char[] copy = Arrays.copyOf(buf.array(), buf.capacity()...

readMoreChars(); L182: } L183: } else if (result.isError()) { L184: // Only reach here if a CharsetEncoder with non-REPLACE settings is used. L185: result.throwException(); L186: return 0; // Not called. L187: } L188: } L189: } L190: } L191: L192: /** Returns a new CharBuffer identical to buf, except twice the capacity. */ L193: private static CharBuffer grow(CharBuffer buf) { L194: char[] copy = Arrays.copyOf(buf.array(), buf.capacity()...

K> keyComparator) { L374: super.orderKeysBy(keyComparator); L375: return this; L376: } L377: L378: /** L379: * Specifies the ordering of the generated multimap's values for each key. L380: * L381: * <p>If this method is called, the sets returned by the {@code get()} method of the generated L382: * multimap and its {@link Multimap#asMap()} view are {@link ImmutableSortedSet} instances. L383: * However, serialization does not preserve that property, though it does...

collection that supports order-independent equality, like {@link Set}, but may have duplicate L37: * elements. A multiset is also sometimes called a <i>bag</i>. L38: * L39: * <p>Elements of a multiset that are equal to one another are referred to as <i>occurrences</i> of L40: * the same single element. The total number of occurrences of an element in a multiset is called L41: * the <i>count</i> of that element (the terms "frequency" and "multiplicity" are equivalent, but L42: * not used in this API). Since...

java.util.Collection; L25:import java.util.Map; L26:import java.util.Set; L27:import javax.annotation.CheckForNull; L28:import org.checkerframework.checker.nullness.qual.Nullable; L29: L30:/** L31: * A collection that associates an ordered pair of keys, called a row key and a column key, with a L32: * single value. A table may be sparse, with only a small fraction of row key / column key pairs L33: * possessing a corresponding value. L34: * L35: * <p>The mappings corresponding to a given row key may be...

public void testRetainAll_containsNonNullWithNull() { L269: initCollectionWithNullElement(); L270: expectReturnsTrue(disjoint); L271: expectContents(); L272: } L273: L274: // retainAll(null) L275: L276: /* L277: * AbstractCollection fails the retainAll(null) test when the subject L278: * collection is empty, but we'd still like to test retainAll(null) when we L279: * can. We split the test into empty and non-empty cases. This allows us to L280: * suppress only the former. L281:...

than [maxRequests] requests are in flight when this is invoked, those requests will L48: * remain in flight. L49: */ L50: var maxRequests = 64 L51: get() = this.withLock { field } L52: set(maxRequests) { L53: require(maxRequests >= 1) { "max < 1: $maxRequests" } L54: this.withLock { L55: field = maxRequests L56: } L57: promoteAndExecute() L58: } L59: L60: /** L61: * The maximum number of requests for each host to execute concurrently. This limits requests...

`windowSizeIncrement` bytes can be sent on `streamId`, or the L519: * connection if `streamId` is zero. L520: */ L521: fun windowUpdate( L522: streamId: Int, L523: windowSizeIncrement: Long, L524: ) L525: L526: /** L527: * Called when reading a headers or priority frame. This may be used to change the stream's L528: * weight from the default (16) to a new value. L529: * L530: * @param streamId stream which has a priority change. L531: * @param streamDependency...

L504: try { L505: ByteStreams.exhaust(decodingStream); L506: fail("Expected DecodingException"); L507: } catch (DecodingException expected) { L508: // Don't assert on the expectedMessage; the messages for exceptions thrown from the L509: // decoding stream may differ from the messages for the decode methods. L510: } catch (IOException e) { L511: fail("Expected DecodingException but got: " + e); L512: } L513: } L514: };...

it L340: * won't compile on Java 7, while if we don't include the method then the compiler will complain L341: * that an abstract method is unimplemented. So instead we use a dynamic proxy to get an L342: * implementation. If the method being called on the {@code TypeVariable} instance has the same L343: * name as one of the public methods of {@link TypeVariableImpl}, the proxy calls the same method L344: * on its instance of {@code TypeVariableImpl}. Otherwise it throws {@link L345: *...