Search Options

Results per page
Sort
Preferred Languages
Advance

Results 561 - 570 of 835 for streams (0.1 sec)

  1. 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()));
                    System.getenv().entrySet().forEach(e -> logger.debug("Env: {}={}", e.getKey(), e.getValue()));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java

        @PluginFactory
        public static ErrorToWarnRewritePolicy createPolicy(@PluginAttribute("loggers") final String loggerNamePrefix) {
            final String[] loggerNames = loggerNamePrefix != null
                    ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n])
                    : new String[0];
            return new ErrorToWarnRewritePolicy(loggerNames);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ImmutableAsList.java

          return collection.asList();
        }
    
        private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      @Override
      Object writeReplace() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/ImmutableMapTest.java

    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collector;
    import java.util.stream.Stream;
    import junit.framework.Test;
    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/Call.kt

    package okhttp3
    
    import okio.IOException
    import okio.Timeout
    
    /**
     * A call is a request that has been prepared for execution. A call can be canceled. As this object
     * represents a single request/response pair (stream), it cannot be executed twice.
     */
    interface Call : Cloneable {
      /** Returns the original request that initiated this call. */
      fun request(): Request
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java

        }
    
        public void setClientMap(final Map<Pattern, CrawlerClient> clientMap) {
            this.clientMap = clientMap;
        }
    
        @Override
        public void close() {
            clientMap.values().stream().distinct().forEach(client -> {
                try {
                    client.close();
                } catch (final Exception e) {
                    logger.warn("Faild to close {}.", client.getClass().getCanonicalName(), e);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/ImmutableRangeSet.java

    import java.io.ObjectInputStream;
    import java.io.Serializable;
    import java.util.Collections;
    import java.util.Iterator;
    import java.util.List;
    import java.util.NoSuchElementException;
    import java.util.Set;
    import java.util.stream.Collector;
    import javax.annotation.CheckForNull;
    
    /**
     * A {@link RangeSet} whose contents will never change, with many other important properties
     * detailed at {@link ImmutableCollection}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  8. .github/workflows/mint/nginx-1-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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 31 21:38:10 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ImmutableAsList.java

          return collection.asList();
        }
    
        private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      @Override
      Object writeReplace() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/BinaryTransformer.java

                resultData.setEncoding(responseData.getCharSet());
                return resultData;
            } catch (final IOException e) {
                throw new CrawlerSystemException("Could not convert the input stream.", e);
            }
    
        }
    
        /*
         * (non-Javadoc)
         *
         * @see
         * org.codelibs.fess.crawler.transformer.Transformer#getData(org.codelibs.fess.crawler.entity
         * .AccessResultData)
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.8K bytes
    - Viewed (0)
Back to top