- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 74 for Streams (0.17 sec)
-
internal/grid/grid_test.go
start := time.Now() stream, err := handler.Call(context.Background(), remoteConn, &testRequest{Num: 1, String: testPayload}) errFatal(err) go func() { defer close(stream.Requests) for i := 0; i < payloads; i++ { // t.Log("sending new client request") stream.Requests <- &testRequest{Num: i, String: testPayload} } }() var n int err = stream.Results(func(resp *testResponse) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* * @since 33.2.0 (available since 21.0 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. @Beta // TODO: b/288085449 - Remove. public static <E> Collector<E, ?, ImmutableSortedMultiset<E>> toImmutableSortedMultiset( Comparator<? super E> comparator) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 35.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMultiset.java
* * @since 33.2.0 (available since 21.0 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. @Beta // TODO: b/288085449 - Remove. public static <E> Collector<E, ?, ImmutableMultiset<E>> toImmutableMultiset() { return CollectCollectors.toImmutableMultiset(Function.identity(), e -> 1); } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.6K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
type: string maxConcurrentStreams: description: The maximum number of concurrent streams allowed for a peer on one HTTP/2 connection. format: int32 type: integer
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMap.java
import java.util.Map; import java.util.NavigableMap; import java.util.SortedMap; import java.util.TreeMap; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collector; import java.util.stream.Collectors; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 53.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableRangeMap.java
* * @since 33.2.0 (available since 23.1 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. @Beta // TODO: b/288085449 - Remove. public static <T extends @Nullable Object, K extends Comparable<? super K>, V> Collector<T, ?, ImmutableRangeMap<K, V>> toImmutableRangeMap(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 14.5K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/crd-all.gen.yaml
type: string maxConcurrentStreams: description: The maximum number of concurrent streams allowed for a peer on one HTTP/2 connection. format: int32 type: integer
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedSet.java
* * @since 33.2.0 (available since 21.0 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. @Beta // TODO: b/288085449 - Remove. public static <E> Collector<E, ?, ImmutableSortedSet<E>> toImmutableSortedSet( Comparator<? super E> comparator) { return CollectCollectors.toImmutableSortedSet(comparator);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 36.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMap.java
import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.SortedMap; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collector; import java.util.stream.Collectors; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 41.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSet.java
/** * Returns a {@code Collector} that accumulates the input elements into a new {@code * ImmutableSet}. Elements appear in the resulting set in the encounter order of the stream; if * the stream contains duplicates (according to {@link Object#equals(Object)}), only the first * duplicate in encounter order will appear in the result. * * @since 33.2.0 (available since 21.0 in guava-jre) */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.6K bytes - Viewed (0)