- Sort Score
- Result 10 results
- Languages All
Results 781 - 790 of 841 for collectors (0.1 sec)
-
guava-tests/test/com/google/common/primitives/LongsTest.java
import com.google.common.testing.NullPointerTester; import com.google.common.testing.SerializableTester; import java.math.BigInteger; import java.util.Arrays; import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.List; import java.util.Random; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link Longs}.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 02:56:12 UTC 2024 - 29.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
migrateTarget *Target // Number of events per HTTP send to webhook target // this is ideally useful only if your endpoint can // support reading multiple events on a stream for example // like : Splunk HTTP Event collector, if you are unsure // set this to '1'. batchSize int payloadType string // store to persist and replay the logs to the target // to avoid missing events when the target is down.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
- Fixes a bug in the garbage collector controller which could block indefinitely on a cache sync failure. This fix allows the garbage collector to eventually continue garbage collecting other resources if a given resource cannot be listed or watched. Any objects in the unsynced resource type with owner references with `blockOwnerDeletion: true` will not be known to the garbage collector. Use of `blockOwnerDeletion` has always been best-effort and racy on startup...
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Oct 29 20:17:52 UTC 2024 - 121.6K bytes - Viewed (0) -
guava/src/com/google/common/io/Closer.java
import java.util.ArrayDeque; import java.util.Deque; import java.util.logging.Level; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Closeable} that collects {@code Closeable} resources and closes them all when it is * {@linkplain #close closed}. This was intended to approximately emulate the behavior of Java 7's
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 07 15:26:58 UTC 2024 - 10.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/ToStringHelperTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 09 21:19:18 UTC 2024 - 21.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeRangeMap.java
import static com.google.common.base.Predicates.not; import static com.google.common.collect.Iterators.emptyIterator; import static com.google.common.collect.Maps.immutableEntry; import static java.util.Collections.emptyMap; import static java.util.Objects.requireNonNull; import com.google.common.annotations.GwtIncompatible; import com.google.common.base.MoreObjects; import com.google.common.base.Predicate;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 22.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketException; import java.security.MessageDigest; import java.util.Arrays; import java.util.Collections; import java.util.LinkedList; import java.util.List; import java.util.ListIterator; import java.util.Locale; import java.util.Set; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
.github/actions/people/app/main.py
import logging import subprocess import sys from collections import Counter, defaultdict from datetime import datetime, timedelta, timezone from pathlib import Path from typing import Any, Container, DefaultDict, Dict, List, Set, Union import httpx import yaml from github import Github from pydantic import BaseModel, SecretStr from pydantic_settings import BaseSettings github_graphql_url = "https://api.github.com/graphql"
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Aug 17 04:13:50 UTC 2024 - 19.2K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
import java.nio.channels.FileChannel.MapMode; import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.List; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Provides utility methods for working with {@linkplain File files}. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jul 22 19:03:12 UTC 2024 - 33.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* addCausalChain. */ boolean unused = addCausalChain(seen, requireNonNull(tryInternalFastPathGetFailure())); } } /** * Collects the result (success or failure) of one input future. The input must not have been * cancelled. For details on when this is called, see {@link #collectOneValue}. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0)