Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 857 for jstream (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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 {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  2. 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 {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  3. 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;
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  4. 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;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 05 23:15:58 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  5. 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) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/EnumMultiset.java

        return Multisets.iteratorImpl(this);
      }
    
      @GwtIncompatible // java.io.ObjectOutputStream
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(type);
        Serialization.writeMultiset(this, stream);
      }
    
      /**
       * @serialData the {@code Class<E>} for the enum type, the number of distinct elements, the first
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/ldap/LdapUser.java

            return stream(getPermissions()).get(stream -> stream.filter(s -> s.startsWith(fessConfig.getRoleSearchRolePrefix()))
                    .map(s -> s.substring(1))
                    .toArray(n -> new String[n]));
        }
    
        @Override
        public String[] getGroupNames() {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/suggest/converter/KatakanaConverter.java

            try (TokenStream stream = createTokenStream(rd)) {
                if (stream == null) {
                    throw new IOException("Invalid tokenizer.");
                }
                stream.reset();
    
                int offset = 0;
                while (stream.incrementToken()) {
                    final CharTermAttribute att = stream.getAttribute(CharTermAttribute.class);
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                final Stream<QueryLog> stream = Stream.of(queryLogs);
                if (parallel) {
                    stream.parallel();
                }
                final SuggestItem[] array = stream.flatMap(queryLog -> contentsParser
                        .parseQueryLog(queryLog, supportedFields, tagFieldNames, roleFieldName, readingConverter, normalizer)
                        .stream()).toArray(SuggestItem[]::new);
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 34.4K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                                }
                            });
                            final List<String> newGroupList = stream(user.getGroupNames()).get(stream -> stream.collect(Collectors.toList()));
                            stream(user.getGroupNames()).of(stream -> stream.forEach(name -> {
                                if (oldGroupList.contains(name)) {
                                    oldGroupList.remove(name);
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 86.3K bytes
    - Click Count (0)
Back to Top