Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 989 for asStream (0.07 sec)

  1. android/guava-tests/test/com/google/common/math/StatsTesting.java

          BigInteger.valueOf(Long.MAX_VALUE)
              .multiply(BigInteger.valueOf(Long.MAX_VALUE))
              .divide(BigInteger.valueOf(16L))
              .doubleValue();
    
      /**
       * Returns a stream of a million primitive doubles. The stream is parallel, which should cause
       * {@code collect} calls to run in multithreaded mode, so testing the combiner as well as the
       * supplier and accumulator.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  2. buildscripts/upgrade-tests/nginx.conf

    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    
    events {
        worker_connections  1024;
    }
    
    
    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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Nov 21 18:41:30 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PasswordBasedExtractor.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.misc.Pair;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  4. internal/s3select/csv/args.go

    	args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter
    	args.CommentCharacter = defaultCommentCharacter
    	args.AllowQuotedRecordDelimiter = false
    
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			tagName := se.Name.Local
    			switch tagName {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/FessApiAction.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.api;
    
    import java.util.Locale;
    import java.util.stream.Collectors;
    
    import org.codelibs.fess.app.service.AccessTokenService;
    import org.codelibs.fess.app.web.api.ApiResult.ApiErrorResponse;
    import org.codelibs.fess.app.web.api.ApiResult.Status;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/pac/kerberos/KerberosApRequest.java

                throw new PACDecodingException("Empty kerberos ApReq");
            }
    
            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);
            }
            return sequence;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  7. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Dec 09 15:58:48 UTC 2025
    - 34.3K bytes
    - Viewed (0)
  8. 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: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 02:01:26 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

       * @serialData the ConcurrentMap of elements and their counts.
       */
        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(countMap);
      }
    
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        @SuppressWarnings("unchecked") // reading data stored by writeObject
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleMappingDelegate.java

    import javax.inject.Singleton;
    
    import java.util.ArrayList;
    import java.util.Comparator;
    import java.util.LinkedHashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.TreeMap;
    import java.util.stream.Collectors;
    
    import org.apache.maven.execution.MavenSession;
    import org.apache.maven.lifecycle.Lifecycle;
    import org.apache.maven.lifecycle.LifecycleMappingDelegate;
    import org.apache.maven.model.Plugin;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Dec 13 23:04:37 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top