- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 681 for delete (0.03 sec)
-
BytesTest.java
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);...github.com/google/guava/android/guava-tests/tes...Sat Oct 19 02:56:12 UTC 2024 17.3K bytes -
RealWebSocketTest.kt
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)...github.com/square/okhttp/okhttp/src/test/java/o...Thu Apr 11 01:59:58 UTC 2024 18.5K bytes -
CharSink.java
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...github.com/google/guava/android/guava/src/com/g...Thu Oct 31 14:20:11 UTC 2024 6.8K bytes -
ImmutableGraph.java
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>...github.com/google/guava/guava/src/com/google/co...Tue Feb 01 16:30:37 UTC 2022 7.1K bytes -
feature_enhancement_request.yaml
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...github.com/google/guava/.github/ISSUE_TEMPLATE/...Fri Nov 17 18:47:47 UTC 2023 3.9K bytes -
TaskQueue.kt
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...github.com/square/okhttp/okhttp/src/main/kotlin...Mon Jan 08 01:13:22 UTC 2024 7.5K bytes -
LittleEndianDataInputStream.java
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...github.com/google/guava/android/guava/src/com/g...Wed May 17 14:35:11 UTC 2023 7.3K bytes -
TestUtilJvm.kt
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...github.com/square/okhttp/okhttp-testing-support...Thu Apr 11 22:09:35 UTC 2024 4.3K bytes -
CharsTest.java
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);...github.com/google/guava/android/guava-tests/tes...Sat Oct 19 02:56:12 UTC 2024 25.6K bytes -
DoublesTest.java
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...github.com/google/guava/android/guava-tests/tes...Sat Oct 19 02:56:12 UTC 2024 32.2K bytes