Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 850 for Stream (0.04 sec)

  1. android/guava/src/com/google/common/collect/ImmutableBiMap.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Map;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BiMap} whose contents will never change, with many other important properties detailed
     * at {@link ImmutableCollection}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 22.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/api/admin/fileauth/ApiAdminFileauthAction.java

     */
    package org.codelibs.fess.app.web.api.admin.fileauth;
    
    import static org.codelibs.fess.app.web.admin.fileauth.AdminFileauthAction.getFileAuthentication;
    
    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.FileAuthPager;
    import org.codelibs.fess.app.service.FileAuthenticationService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/AbstractXmlExtractor.java

         */
        protected ExtractData createExtractData(final String content) {
            return new ExtractData(extractString(content));
        }
    
        /**
         * Detects the encoding of the input stream.
         * @param bis The buffered input stream.
         * @return The detected encoding.
         */
        protected String getEncoding(final BufferedInputStream bis) {
            final byte[] b = new byte[preloadSizeForCharset];
            try {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  4. 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)
  5. docs/resiliency/nginx.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: Sat Dec 21 04:24:45 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. CHANGELOG.md

        receiving stream to process it.
    
        This change may increase OkHttp's memory use for applications that make many concurrent HTTP
        calls and that can receive data faster than they can process it. Previously, OkHttp limited
        HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB
        of unacknowledged data per stream and no per-connection limit.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (2)
  7. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                return;
            }
    
            if (logger.isDebugEnabled()) {
                try {
                    ManagementFactory.getRuntimeMXBean().getInputArguments().stream().forEach(s -> logger.debug("Parameter: {}", s));
                    System.getProperties().entrySet().stream().forEach(e -> logger.debug("Property: {}={}", e.getKey(), e.getValue()));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. compat/maven-builder-support/src/main/java/org/apache/maven/building/StringSource.java

        }
    
        @Override
        public String getLocation() {
            return location;
        }
    
        /**
         * Gets the content of this source.
         *
         * @return The underlying character stream, never {@code null}.
         */
        public String getContent() {
            return content;
        }
    
        @Override
        public String toString() {
            return getLocation();
        }
    
        @Override
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jan 15 18:51:29 UTC 2025
    - 3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/pac/kerberos/KerberosTicket.java

                throw new PACDecodingException("Empty kerberos ticket");
            }
    
            ASN1Sequence sequence;
            try {
                try (ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token))) {
                    sequence = ASN1Util.as(ASN1Sequence.class, stream);
                }
            } catch (IOException e) {
                throw new PACDecodingException("Malformed kerberos ticket", e);
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. compat/maven-compat/src/test/java/org/apache/maven/SimpleLookup.java

        private final List<Object> objects;
    
        public SimpleLookup(List<Object> objects) {
            this.objects = objects;
        }
    
        @Override
        public <T> T lookup(Class<T> type) {
            return objects.stream()
                    .filter(type::isInstance)
                    .map(type::cast)
                    .findAny()
                    .orElseThrow(() -> new LookupException("No service of type " + type));
        }
    
        @Override
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top