- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 738 for STREAM (0.89 sec)
-
src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java
stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p))); putResultDataBody(dataMap, fessConfig.getIndexFieldRole(), roleTypeList); // virtualHosts putResultDataBody(dataMap, fessConfig.getIndexFieldVirtualHost(), stream(crawlingConfig.getVirtualHosts()).get(stream -> stream.filter(StringUtil::isNotBlank).collect(Collectors.toList())));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 23.5K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/reflect/annotations/impl/DefaultTypeAnnotationMetadataStore.java
import java.util.List; import java.util.Map; import java.util.Optional; import java.util.Set; import java.util.function.Predicate; import java.util.stream.Collectors; import java.util.stream.Stream; import static java.util.Comparator.comparing; import static java.util.stream.Collectors.joining; import static org.gradle.api.problems.Severity.ERROR; import static org.gradle.internal.deprecation.Documentation.userManual;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 21:54:36 UTC 2024 - 37.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java
@PostConstruct public void init() { if (logger.isDebugEnabled()) { logger.debug("Initialize {}", this.getClass().getSimpleName()); } stream(ComponentUtil.getFessConfig().getSearchDefaultPermissionsAsArray()).of(stream -> stream.forEach(name -> { defaultRoleList.add(name); })); } public Set<String> build(final SearchRequestType searchRequestType) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java
*/ package org.codelibs.fess.helper; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.regex.Pattern; import java.util.stream.Collectors; import javax.annotation.PostConstruct;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.7K bytes - Viewed (0) -
tensorflow/cc/saved_model/fingerprinting.cc
{ // Local scope guarantees coded stream will be trimmed (ensures // serialization determinism). // Unfortunately the saving process itself isn't deterministic, so the // checksum may still change since the saved_model proto may be different. StringOutputStream stream(&saved_model_serialized); CodedOutputStream output(&stream); output.SetSerializationDeterministic(true);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 26 00:24:44 UTC 2024 - 9.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.8K bytes - Viewed (0) -
maven-di/src/main/java/org/apache/maven/di/impl/ReflectionUtils.java
import java.util.function.Function; import java.util.function.Supplier; import java.util.regex.Pattern; import java.util.stream.Stream; import org.apache.maven.api.annotations.Nullable; import org.apache.maven.api.di.*; import org.apache.maven.di.Key; import static java.util.stream.Collectors.toList; public final class ReflectionUtils {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Feb 09 17:13:31 UTC 2024 - 16K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
ioe = new InterruptedIOException(root.getMessage()); ioe.initCause(root); } return ioe; } /** * Closes this input stream and releases any system resources associated with the stream. * * @throws IOException * if a network error occurs */ @Override public void close () throws IOException { try {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun May 17 08:55:14 UTC 2020 - 13.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
sleepNanos(response.headersDelayNanos) stream.writeHeaders(response.toHttp2Headers(), outFinished, flushHeaders) if (trailers.size > 0) { stream.enqueueTrailers(trailers) } pushPromises(stream, request, response.pushPromises) if (body != null) { sleepNanos(bodyDelayNanos) val responseBodySink = stream.getSink().withThrottlingAndSocketPolicy(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/QueryHelper.java
} public void addDefaultSort(final String fieldName, final String order) { final List<SortBuilder<?>> list = new ArrayList<>(); if (defaultSortBuilders != null) { stream(defaultSortBuilders).of(stream -> stream.forEach(builder -> list.add(builder))); } list.add(createFieldSortBuilder(fieldName, SortOrder.DESC.toString().equalsIgnoreCase(order) ? SortOrder.DESC : SortOrder.ASC));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.9K bytes - Viewed (0)