Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,021 for streams (0.37 sec)

  1. impl/maven-core/src/test/java/org/apache/maven/project/DefaultMavenProjectBuilderTest.java

                assertTrue(project.getInjectedProfileIds().get("external").stream().anyMatch("external-profile"::equals));
                assertTrue(project.getInjectedProfileIds().get(id).stream().noneMatch("profile1"::equals));
                assertTrue(project.getInjectedProfileIds().get(id).stream().noneMatch("profile2"::equals));
                assertTrue(project.getInjectedProfileIds().get(id).stream().anyMatch("active-by-default"::equals));
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Nov 18 17:20:31 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultMojoExecutionConfigurator.java

    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    
    import java.util.Collection;
    import java.util.Set;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.services.MessageBuilder;
    import org.apache.maven.api.services.MessageBuilderFactory;
    import org.apache.maven.api.xml.XmlNode;
    import org.apache.maven.api.xml.XmlService;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Mar 25 09:45:07 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionStreamTester.java

      /*
       * We're not really testing the implementation of Stream, only that we're getting a Stream
       * that corresponds to the expected elements.
       */
    
      @CollectionFeature.Require(absent = KNOWN_ORDER)
      public void testStreamToArrayUnknownOrder() {
        Helpers.assertEqualIgnoringOrder(getSampleElements(), asList(collection.stream().toArray()));
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Oct 31 14:51:04 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/base/login/EntraIdCredential.java

                        }
                    }
                    stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s))));
                    stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s))));
                    permissions = permissionSet.stream().filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]);
                }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

     */
    package org.codelibs.fess.app.service;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.io.IOException;
    import java.io.Reader;
    import java.io.Writer;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/mylasta/action/FessUserBean.java

        }
    
        public boolean hasRole(final String role) {
            return stream(user.getRoleNames()).get(stream -> stream.anyMatch(s -> s.equals(role)));
        }
    
        public boolean hasRoles(final String[] acceptedRoles) {
            return stream(user.getRoleNames())
                    .get(stream -> stream.anyMatch(s1 -> stream(acceptedRoles).get(s3 -> s3.anyMatch(s2 -> s2.equals(s1)))));
        }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

            split(fessConfig.getSuggestFieldContents(), ",")
                    .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add));
            split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add));
            split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(roleFieldNameSet::add));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/query/QueryFieldConfig.java

        }
    
        /**
         * Processes the highlighted fields using the provided stream consumer.
         *
         * @param stream consumer that processes the stream of highlighted field names
         */
        public void highlightedFields(final Consumer<Stream<String>> stream) {
            stream(highlightedFields).of(stream);
        }
    
        /**
         * Gets the fields that can be searched against.
         *
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

          )
          request.isChunked -> newChunkedSink() // Stream a request body of unknown length.
          contentLength != -1L -> newKnownLengthSink() // Stream a request body of a known length.
          else -> // Stream a request body of a known length.
            throw IllegalStateException(
              "Cannot stream a request body without chunked encoding or a known content length!",
            )
        }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  10. guava/src/com/google/common/collect/LinkedHashMultiset.java

      @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultiset(this, stream);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int distinctElements = stream.readInt();
        setBackingMap(new LinkedHashMap<E, Count>());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 05 23:15:58 UTC 2025
    - 3.8K bytes
    - Viewed (0)
Back to top