- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 565 for stream (0.17 sec)
-
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 85K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
* * <p><b>Java 8+ users:</b> If passing a single element {@code e}, the {@code Stream} equivalent * of this method is {@code Stream.generate(() -> e)}. Otherwise, put the elements in a collection * and use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}. */ @SafeVarargs public static <T extends @Nullable Object> Iterable<T> cycle(T... elements) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 42.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/StreamsTest.java
Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); Stream<String> concatenated = Stream.<Stream<String>>of(Stream.of("a"), streamB, Stream.empty(), Stream.of("c", "d")) .reduce(Stream.empty(), Stream::concat); assertThat(concatenated).containsExactly("a", "b", "c", "d").inOrder(); concatenated.close(); assertThat(closeCountB.get()).isEqualTo(1); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 20K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(valueComparator()); Serialization.writeMultimap(this, stream); } @CheckForNull Comparator<? super V> valueComparator() { return emptySet instanceof ImmutableSortedSet
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 23.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/GeoInfo.java
final String[] geoFields = fessConfig.getQueryGeoFieldsAsArray(); final Map<String, List<QueryBuilder>> geoMap = new HashMap<>(); StreamUtil.stream(request.getParameterMap()) .of(stream -> stream.filter(e -> e.getKey().startsWith("geo.") && e.getKey().endsWith(".point")).forEach(e -> { final String key = e.getKey(); for (final String geoField : geoFields) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.7K bytes - Viewed (0) -
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;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/login/AzureAdCredential.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]); }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.1K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/LifecycleRegistry.java
*/ package org.apache.maven.api.services; import java.util.List; import java.util.stream.Stream; import java.util.stream.StreamSupport; import org.apache.maven.api.Lifecycle; public interface LifecycleRegistry extends ExtensibleEnumRegistry<Lifecycle>, Iterable<Lifecycle> { default Stream<Lifecycle> stream() { return StreamSupport.stream(spliterator(), false); } List<String> computePhases(Lifecycle lifecycle);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EnumBiMap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); stream.writeObject(valueTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading fields populated by writeObject
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Aug 24 01:40:03 GMT 2023 - 6.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/accesstoken/AdminAccesstokenAction.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.admin.accesstoken; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.stream.Collectors; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 14.7K bytes - Viewed (0)