Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 779 for asStream (0.15 sec)

  1. internal/grid/handlers.go

    			for req := range reqT {
    				b, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize()))
    				if err != nil {
    					gridLogOnceIf(ctx, err, err.Error())
    				}
    				h.PutRequest(req)
    				stream.Requests <- b
    			}
    		}()
    	} else if stream.Requests != nil {
    		xioutil.SafeClose(stream.Requests)
    	}
    
    	return &TypedStream[Req, Resp]{responses: stream, newResp: h.NewResponse, Requests: reqT}, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  2. internal/s3select/simdj/record.go

    		return nil, err
    	}
    	if cap(dst.KVS) < len(elems.Elements) {
    		dst.KVS = make(jstream.KVS, 0, len(elems.Elements))
    	}
    	for _, elem := range elems.Elements {
    		v, err := sql.IterToValue(elem.Iter)
    		if err != nil {
    			v, err = elem.Iter.Interface()
    			if err != nil {
    				panic(err)
    			}
    		}
    		dst.KVS = append(dst.KVS, jstream.KV{
    			Key:   elem.Name,
    			Value: v,
    		})
    	}
    	return dst, nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

            final Map<String, UserInfo> userInfoMap = new HashMap<>();
            queue.stream().forEach(searchLog -> {
                final String userAgent = searchLog.getUserAgent();
                final boolean isBot =
                        userAgent != null && stream(botNames).get(stream -> stream.anyMatch(botName -> userAgent.indexOf(botName) >= 0));
                if (!isBot) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 22 02:07:37 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/Resources.java

              public List<String> getResult() {
                return result;
              }
            });
      }
    
      /**
       * Copies all bytes from a URL to an output stream.
       *
       * @param from the URL to read from
       * @param to the output stream
       * @throws IOException if an I/O error occurs
       */
      public static void copy(URL from, OutputStream to) throws IOException {
        asByteSource(from).copyTo(to);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/util/LogStream.java

        public LogStream( PrintStream stream ) {
            super( stream );
        }
    
        public static void setLevel( int level ) {
            LogStream.level = level;
        }
        /**
         * This must be called before <tt>getInstance</tt> is called or
         * it will have no effect.
         */
        public static void setInstance( PrintStream stream ) {
            inst = new LogStream( stream );
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 1.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbFileInputStream.java

                ioe = new InterruptedIOException(root.getMessage());
                ioe.initCause(root);
            }
            return ioe;
        }
    
    
        /**
         * Closes this input stream and releases any system resources associated with the stream.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void close () throws IOException {
            try {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/Lifecycle.java

        String id();
    
        /**
         * Collection of phases for this lifecycle
         */
        Collection<Phase> phases();
    
        /**
         * Stream of phases containing all child phases recursively.
         */
        default Stream<Phase> allPhases() {
            return phases().stream().flatMap(Phase::allPhases);
        }
    
        /**
         * Collection of aliases.
         */
        Collection<Alias> aliases();
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Sep 24 07:54:24 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

    import java.nio.file.StandardCopyOption;
    import java.util.Comparator;
    import java.util.stream.Stream;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.fess.exception.ThemeException;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/query/QueryCommand.java

            }
            final float importantContantLangBoost = fessConfig.getQueryBoostImportantContentLangAsDecimal().floatValue();
            getQueryLanguages().ifPresent(langs -> stream(langs).of(stream -> stream.forEach(lang -> {
                defaultQuery.add(
                        builder.apply(fessConfig.getIndexFieldTitle() + "_" + lang, fessConfig.getQueryBoostTitleLangAsDecimal().floatValue()));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java

     */
    package org.codelibs.fess.helper;
    
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top