- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 882 for Streams (0.19 sec)
-
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* explained in the {@link Comparator} documentation. */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. static <E> Collector<E, ?, ImmutableSortedMultiset<E>> toImmutableSortedMultiset( Comparator<? super E> comparator) { return toImmutableSortedMultiset(comparator, Function.identity(), e -> 1); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 35.3K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* <p>To react to events, we recommend a reactive-streams framework like <a * href="https://github.com/ReactiveX/RxJava/wiki">RxJava</a> (supplemented with its <a * href="https://github.com/ReactiveX/RxAndroid">RxAndroid</a> extension if you are building for * Android) or <a href="https://projectreactor.io/">Project Reactor</a>. (For the basics of * translating code from using an event bus to using a reactive-streams framework, see these two
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Aug 25 16:37:57 GMT 2021 - 12.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
sleepNanos(response.headersDelayNanos) stream.writeHeaders(response.toHttp2Headers(), outFinished, flushHeaders) if (trailers.size > 0) { stream.enqueueTrailers(trailers) } pushPromises(stream, request, response.pushPromises) if (body != null) { sleepNanos(bodyDelayNanos) val responseBodySink = stream.getSink().withThrottlingAndSocketPolicy(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
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 Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Aug 24 01:40:03 GMT 2023 - 17.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableTable.java
* if the row, column, or value functions return null on any input. */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. static <T extends @Nullable Object, R, C, V> Collector<T, ?, ImmutableTable<R, C, V>> toImmutableTable( Function<? super T, ? extends R> rowFunction, Function<? super T, ? extends C> columnFunction,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 08 18:58:42 GMT 2023 - 17.4K bytes - Viewed (0) -
internal/grid/manager.go
if debugPrint { fmt.Println("RegisterStreamingHandler: subroute:", h.Subroute) } if h.Subroute == "" { if m.handlers.hasAny(id) && !id.isTestHandler() { return ErrHandlerAlreadyExists } m.handlers.streams[id] = &h return nil } subID := makeSubHandlerID(id, h.Subroute) if m.handlers.hasSubhandler(subID) && !id.isTestHandler() { return ErrHandlerAlreadyExists } m.handlers.subStreams[subID] = &h
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
} // NewDummyDataGen returns a ReadSeeker over the first `totalLength` // bytes from the infinite stream consisting of repeated // concatenations of `alphabets`. // // The skipOffset (generally = 0) can be used to skip a given number // of bytes from the beginning of the infinite stream. This is useful // to compare such streams of bytes that may be split up, because: // // Given the function: // // f := func(r io.Reader) string {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 4.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java
response.off += n; } while( len > 0 && n == r ); return (int)(fp - start); } /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server. */
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 7.9K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/AbstractByteHasher.java
import java.nio.ByteBuffer; import java.nio.ByteOrder; /** * Abstract {@link Hasher} that handles converting primitives to bytes using a scratch {@code * ByteBuffer} and streams all bytes to a sink to compute the hash. * * @author Colin Decker */ @ElementTypesAreNonnullByDefault abstract class AbstractByteHasher extends AbstractHasher {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jun 15 20:59:00 GMT 2022 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/package-info.java
* <li>{@link Maps} * <li>{@link MoreCollectors} * <li>{@link Multimaps} * <li>{@link Multisets} * <li>{@link ObjectArrays} * <li>{@link Queues} * <li>{@link Sets} * <li>{@link Streams} * <li>{@link Tables} * </ul> * * <h2>Abstract implementations</h2> * * <ul> * <li>{@link AbstractIterator} * <li>{@link AbstractSequentialIterator} * <li>{@link UnmodifiableIterator}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Jul 06 16:29:45 GMT 2023 - 5K bytes - Viewed (0)