Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 771 for Streams (2.15 sec)

  1. guava-tests/test/com/google/common/hash/BloomFilterTest.java

    import java.io.ByteArrayOutputStream;
    import java.lang.Thread.UncaughtExceptionHandler;
    import java.math.RoundingMode;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Random;
    import java.util.stream.Stream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Tests for SimpleGenericBloomFilter and derived BloomFilter views.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. README.md

    =====
    
    A simple cURL-like Java HTTP client.
    
    ## Features
    
    - Fluent API for building HTTP requests (GET, POST, PUT, DELETE, HEAD, OPTIONS, CONNECT, TRACE)
    - Support for query parameters, headers, body (String or stream), compression, SSL configuration, proxies, and timeouts
    - Automatic in-memory or on-disk caching of request/response bodies
    - Synchronous and asynchronous (callback) execution
    - Minimal dependencies (only Apache Commons IO)
    
    Registered: Thu Sep 04 15:34:10 UTC 2025
    - Last Modified: Sat Jul 05 01:11:14 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  3. .github/workflows/mint/nginx-4-node.conf

    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
                          '"$http_user_agent" "$http_x_forwarded_for"';
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/ds/DataStoreFactory.java

    import java.nio.file.Path;
    import java.util.HashSet;
    import java.util.LinkedHashMap;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import javax.xml.parsers.DocumentBuilder;
    import javax.xml.parsers.DocumentBuilderFactory;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/smb1/DosErrorTest.java

     * constants, the tests exercise the data and small helper logic in this
     * test class.
     */
    public class DosErrorTest {
        private static Optional<Integer> findNtStatus(int dosErrorCode) {
            return Arrays.stream(DosError.DOS_ERROR_CODES).filter(pair -> pair[0] == dosErrorCode).map(pair -> pair[1]).findFirst();
        }
    
        @Test
        @DisplayName("DOS_ERROR_CODES is non‑null and non‑empty")
        void testCodesArrayExistence() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. .github/workflows/mint/nginx-8-node.conf

    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
                          '"$http_user_agent" "$http_x_forwarded_for"';
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  7. cmd/metacache-walk.go

    }
    
    // supported FS for Nlink optimization in readdir.
    const (
    	xfs  = "XFS"
    	ext4 = "EXT4"
    )
    
    // WalkDir will traverse a directory and return all entries found.
    // On success a sorted meta cache stream will be returned.
    // Metadata has data stripped, if any.
    // The function tries to quit as fast as the context is canceled to avoid further drive IO
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/TreeMultiset.java

        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(elementSet().comparator());
        Serialization.writeMultiset(this, stream);
      }
    
      @J2ktIncompatible
      @GwtIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        @SuppressWarnings("unchecked")
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.8K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    	o.SetFilter()
    	if o.Transient {
    		o.Create = false
    	}
    
    	// We have 2 cases:
    	// 1) Cold listing, just list.
    	// 2) Returning, but with no id. Start async listing.
    	// 3) Returning, with ID, stream from list.
    	//
    	// If we don't have a list id we must ask the server if it has a cache or create a new.
    	if o.ID != "" && !o.Transient {
    		// Create or ping with handout...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/xml/DocumentBuilderUtil.java

        }
    
        /**
         * Parses the XML.
         *
         * @param builder
         *            {@link DocumentBuilder}; must not be {@literal null}.
         * @param is
         *            Input stream; must not be {@literal null}.
         * @return {@link Document}
         */
        public static Document parse(final DocumentBuilder builder, final InputStream is) {
            assertArgumentNotNull("builder", builder);
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 1.8K bytes
    - Viewed (0)
Back to top