Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,102 for Stream (0.4 sec)

  1. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

    @J2ktIncompatible
    @GwtIncompatible
    public final class LittleEndianDataInputStream extends FilterInputStream implements DataInput {
    
      /**
       * Creates a {@code LittleEndianDataInputStream} that wraps the given stream.
       *
       * @param in the stream to delegate to
       */
      public LittleEndianDataInputStream(InputStream in) {
        super(Preconditions.checkNotNull(in));
      }
    
      /** This method will throw an {@link UnsupportedOperationException}. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 03:49:18 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java

                context.addFieldLog(field, text);
                stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
                return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> buildMatchPhraseQuery(f, text).boost(b * boost));
            }
    
            if (isSearchField(field)) {
                context.addFieldLog(field, text);
                stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/ProtocolHelper.java

            webProtocols = split(fessConfig.getCrawlerWebProtocols(), ",")
                    .get(stream -> stream.filter(StringUtil::isNotBlank).map(s -> s.trim() + ":").toArray(n -> new String[n]));
            fileProtocols = split(fessConfig.getCrawlerFileProtocols(), ",")
                    .get(stream -> stream.filter(StringUtil::isNotBlank).map(s -> s.trim() + ":").toArray(n -> new String[n]));
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Dec 12 13:58:40 UTC 2025
    - 12.4K bytes
    - Viewed (1)
  4. src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java

                            postcard.addReplyTo(fessConfig.getMailReturnPath());
                            if (toAddresses.length > 0) {
                                stream(toAddresses).of(stream -> stream.map(String::trim).forEach(address -> {
                                    postcard.addTo(address);
                                }));
                            } else {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Multimaps.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 86.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/EnumHashBiMap.java

      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(keyTypeOrObjectUnderJ2cl);
        Serialization.writeMap(this, stream);
      }
    
      @SuppressWarnings("unchecked") // reading field populated by writeObject
      @GwtIncompatible // java.io.ObjectInputStream
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 15:50:50 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

            }
        }
    
        /**
         * Writes OpenSearch CAT API responses to the ZIP output stream.
         *
         * @param zos the ZIP output stream to write to
         * @param id the diagnostic ID for organizing files in the ZIP
         */
        protected void writeFesenCat(final ZipOutputStream zos, final String id) {
            Arrays.stream(CAT_NAMES).forEach(name -> {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/relatedquery/ApiAdminRelatedqueryAction.java

     */
    package org.codelibs.fess.app.web.api.admin.relatedquery;
    
    import static org.codelibs.core.stream.StreamUtil.stream;
    import static org.codelibs.fess.app.web.admin.relatedquery.AdminRelatedqueryAction.getRelatedQuery;
    
    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.lang.StringUtil;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ArrayListMultimap.java

      @GwtIncompatible
      @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        expectedValuesPerKey = DEFAULT_VALUES_PER_KEY;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 05 23:15:58 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  10. compat/maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Writer.java

            }
        }
    
        /**
         * Method write.
         *
         * @param stream a stream object
         * @param metadata a Metadata object
         * @throws java.io.IOException java.io.IOException if any
         */
        public void write(OutputStream stream, Metadata metadata) throws java.io.IOException {
            try {
                delegate.write(stream, metadata.getDelegate());
            } catch (XMLStreamException e) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top