- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 1,021 for streams (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)