Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 807 for stream (0.03 sec)

  1. src/main/java/org/codelibs/fess/dict/DictionaryManager.java

                @SuppressWarnings("unchecked")
                final List<Map<String, Object>> fileList = (List<Map<String, Object>>) contentMap.get("file");
                return fileList.stream().map(fileMap -> {
                    try {
                        final String path = fileMap.get("path").toString();
                        final Date timestamp =
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  2. 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)
  3. src/main/java/org/codelibs/fess/app/web/api/admin/group/ApiAdminGroupAction.java

    import static org.codelibs.fess.app.web.admin.group.AdminGroupAction.getGroup;
    import static org.codelibs.fess.app.web.admin.group.AdminGroupAction.validateAttributes;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.GroupPager;
    import org.codelibs.fess.app.service.GroupService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/boostdoc/ApiAdminBoostdocAction.java

     */
    package org.codelibs.fess.app.web.api.admin.boostdoc;
    
    import static org.codelibs.fess.app.web.admin.boostdoc.AdminBoostdocAction.getBoostDocumentRule;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.beans.util.CopyOptions;
    import org.codelibs.fess.app.pager.BoostDocPager;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/Suggester.java

    import java.io.InputStreamReader;
    import java.time.ZonedDateTime;
    import java.time.format.DateTimeFormatter;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ExecutorService;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.suggest.analysis.SuggestAnalyzer;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (3)
  6. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTimingAttackTest.java

                // Analyze timing consistency across threads
                if (!timings.isEmpty()) {
                    double avgTime = timings.stream().mapToLong(Long::longValue).average().orElse(0.0);
                    long maxTime = timings.stream().mapToLong(Long::longValue).max().orElse(0L);
                    long minTime = timings.stream().mapToLong(Long::longValue).min().orElse(0L);
    
                    double variance = (maxTime - minTime) / avgTime;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  7. 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)
  8. .github/workflows/mint/nginx-4-node.conf

        sendfile        on;
        keepalive_timeout  65;
    
        # include /etc/nginx/conf.d/*.conf;
    
        upstream minio {
            server minio1:9000 max_fails=1 fail_timeout=10s;
            server minio2:9000 max_fails=1 fail_timeout=10s;
            server minio3:9000 max_fails=1 fail_timeout=10s;
        }
    
        upstream console {
            ip_hash;
            server minio1:9001;
            server minio2:9001;
            server minio3:9001;
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

         *
         * @return The created OpenSearch client.
         */
        protected Client createClient() {
            final String[] hosts =
                    split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
            final Settings settings = Settings.builder().putList("http.hosts", hosts).build();
            return new HttpClient(settings, null);
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java

            // Verify the cached files have correct names
            List<DirectoryCacheEntry.FileInfo> children = cacheEntry.getChildren();
            assertTrue(children.stream().anyMatch(f -> "file1.txt".equals(f.getName())));
            assertTrue(children.stream().anyMatch(f -> "dir1".equals(f.getName())));
        }
    
        @Test
        public void testUpdateDirectoryCache() throws IOException {
            String directoryPath = "/test/dir";
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 15.9K bytes
    - Viewed (0)
Back to top