Search Options

Results per page
Sort
Preferred Languages
Advance

Results 781 - 790 of 841 for collectors (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. android/guava-tests/test/com/google/common/base/ToStringHelperTest.java

                // CharSequences
                .add("field1", "")
                .add("field2", new StringBuilder())
                // nio CharBuffer (implements CharSequence) is tested separately below
                // Collections and Maps
                .add("field11", Arrays.asList("Hello"))
                .add("field12", new ArrayList<>())
                .add("field13", new HashMap<>())
                // Optionals
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 09 21:19:18 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. .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)
  9. 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)
  10. 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)
Back to top