assertThat(Bytes.toArray(Bytes.asList(array))).isEqualTo(array); L193: } L194: L195: public void testToArray_threadSafe() { L196: for (int delta : new int[] {+1, 0, -1}) { L197: for (int i = 0; i < VALUES.length; i++) { L198: List<Byte> list = Bytes.asList(VALUES).subList(0, i); L199: Collection<Byte> misleadingSize = Helpers.misleadingSizeCollection(delta); L200: misleadingSize.addAll(list); L201: byte[] arr = Bytes.toArray(misleadingSize); L202: assertThat(arr).hasLength(i);...

assertThat(client.processNextFrame()).isTrue() L427: client.listener.assertTextMessage(message) L428: } L429: L430: @Test L431: fun messagesCompressedWhenConfigured() { L432: val headers = headersOf("Sec-WebSocket-Extensions", "permessage-deflate") L433: client.initWebSocket(random, responseHeaders = headers) L434: server.initWebSocket(random, responseHeaders = headers) L435: val message = repeat('a', RealWebSocket.DEFAULT_MINIMUM_DEFLATE_SIZE.toInt()) L436: server.webSocket!!.send(message)...

Writer openStream() throws IOException; L71: L72: /** L73: * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not L74: * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to L75: * {@link #openStream()} when the stream returned by that method does not benefit from additional L76: * buffering. This method returns a new, independent writer each time it is called. L77: * L78: * <p>The caller is responsible for...

DirectedGraphConnections.ofImmutable(node, graph.incidentEdges(node), edgeValueFn) L99: : UndirectedGraphConnections.ofImmutable( L100: Maps.asMap(graph.adjacentNodes(node), edgeValueFn)); L101: } L102: L103: @Override L104: BaseGraph<N> delegate() { L105: return backingGraph; L106: } L107: L108: /** L109: * A builder for creating {@link ImmutableGraph} instances, especially {@code static final} L110: * graphs. Example: L111: * L112: * <pre>{@code L113: * static final ImmutableGraph<Country>...

we make significant changes to existing features in Guava, we really want to be sure L69: that it's for a use case that actually comes up in the real world. We want to hear the L70: real-world use case so the community can discuss and debate whether this feature is actually L71: the *best* way to address the real use case, or whether or not a different approach might be L72: more appropriate. L73: L74: L75: It's okay if you can't provide complete context on a use...

AwaitIdleTask) { L139: return existingTask.latch L140: } L141: for (futureTask in futureTasks) { L142: if (futureTask is AwaitIdleTask) { L143: return futureTask.latch L144: } L145: } L146: L147: // Don't delegate to schedule() because that enforces shutdown rules. L148: val newTask = AwaitIdleTask() L149: if (scheduleAndDecide(newTask, 0L, recurrence = false)) { L150: taskRunner.kickCoordinator(this) L151: } L152: return newTask.latch...

ault L45:public final class LittleEndianDataInputStream extends FilterInputStream implements DataInput { L46: L47: /** L48: * Creates a {@code LittleEndianDataInputStream} that wraps the given stream. L49: * L50: * @param in the stream to delegate to L51: */ L52: public LittleEndianDataInputStream(InputStream in) { L53: super(Preconditions.checkNotNull(in)); L54: } L55: L56: /** This method will throw an {@link UnsupportedOperationException}. */ L57: @CanIgnoreReturnValue // to skip...

APIs may depend on these internal L56: * structures. L57: * L58: * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a L59: * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is L60: * not terminated. L61: * L62: * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of L63: * the internal list. L64: */ L65: @JvmStatic L66: fun fragmentBuffer(buffer: Buffer): Buffer...

assertThat(Chars.toArray(Chars.asList(array))).isEqualTo(array); L612: } L613: L614: public void testToArray_threadSafe() { L615: for (int delta : new int[] {+1, 0, -1}) { L616: for (int i = 0; i < VALUES.length; i++) { L617: List<Character> list = Chars.asList(VALUES).subList(0, i); L618: Collection<Character> misleadingSize = Helpers.misleadingSizeCollection(delta); L619: misleadingSize.addAll(list); L620: char[] arr = Chars.toArray(misleadingSize); L621: assertThat(arr).hasLength(i);...

oArray(Doubles.asList(array))).isEqualTo(array); L546: } L547: L548: public void testToArray_threadSafe() { L549: for (int delta : new int[] {+1, 0, -1}) { L550: for (int i = 0; i < VALUES.length; i++) { L551: List<Double> list = Doubles.asList(VALUES).subList(0, i); L552: Collection<Double> misleadingSize = Helpers.misleadingSizeCollection(delta); L553: misleadingSize.addAll(list); L554: double[] arr = Doubles.toArray(misleadingSize); L555: assertTha...