- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 349 for Streams (0.15 sec)
-
android/guava/src/com/google/common/collect/Ordering.java
* well. * * <h3>Java 8+ users</h3> * * <p>If you are using Java 8+, this class is now obsolete. Most of its functionality is now * provided by {@link java.util.stream.Stream Stream} and by {@link Comparator} itself, and the rest * can now be found as static methods in our new {@link Comparators} class. See each method below
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 39.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
sink.writeInt(payload2) sink.flush() } } /** * Tell the peer to stop creating streams and that we last processed `lastGoodStreamId`, or zero * if no streams were processed. * * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed. * @param errorCode reason for closing the connection.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxer.java
} public void setThisModuleComplete(ProjectSegment projectBuild) { completedBuilds.add(projectBuild); PrintStream stream = printStreams.get(projectBuild); synchronized (stream) { stream.notifyAll(); } disconnectThreadFromProject(); } private void disconnectThreadFromProject() { projectBuildThreadLocal.remove();
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 12.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
connection: Http2Connection, amount: Int, ) { val settings = Settings() settings[Settings.MAX_CONCURRENT_STREAMS] = amount connection.readerRunnable.applyAndAckSettings(true, settings) assertThat(connection.peerSettings[Settings.MAX_CONCURRENT_STREAMS]).isEqualTo(amount) taskFaker.runTasks() } /** Use a helper method so there's no hidden reference remaining on the stack. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else { check(isLocallyInitiated) { "remotely-initiated streams should have headers" } } } /** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/ImmutableListMultimap.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); Serialization.writeMultimap(this, stream); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); int keyCount = stream.readInt(); if (keyCount < 0) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 17.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* weight from the default (16) to a new value. * * @param streamId stream which has a priority change. * @param streamDependency the stream ID this stream is dependent on. * @param weight relative proportion of priority in `[1..256]`. * @param exclusive inserts this stream ID as the sole child of `streamDependency`. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharStreams.java
break; } } return processor.getResult(); } /** * Reads and discards data from the given {@code Readable} until the end of the stream is reached. * Returns the total number of chars read. Does not close the stream. * * @since 20.0 */ @CanIgnoreReturnValue public static long exhaust(Readable readable) throws IOException { long total = 0; long read;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 10.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
* RandomAccess} support, then this operation is guaranteed to be {@code O(1)}. * * <p><b>{@code Stream} equivalent:</b> {@link Streams#findLast Streams.findLast(stream).get()} * * @return the last element of {@code iterable} * @throws NoSuchElementException if the iterable is empty */ @ParametricNullness
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 42.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
* input element is mapped to a key and a stream of values, each of which are put into the * resulting {@code Multimap}, in the encounter order of the stream and the encounter order of the * streams of values. * * <p>Example: * * <pre>{@code * static final ImmutableSetMultimap<Character, Character> FIRST_LETTER_MULTIMAP = * Stream.of("banana", "apple", "carrot", "asparagus", "cherry")
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 23.6K bytes - Viewed (0)