- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 322 for stream (0.14 sec)
-
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultChecksumAlgorithmService.java
return calculate(inputStream, algorithms); } } @Override public Map<ChecksumAlgorithm, String> calculate(InputStream stream, Collection<ChecksumAlgorithm> algorithms) throws IOException { nonNull(stream, "stream"); nonNull(algorithms, "algorithms"); LinkedHashMap<ChecksumAlgorithm, ChecksumCalculator> algMap = new LinkedHashMap<>();
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Thu Dec 21 08:05:10 GMT 2023 - 7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultChecksumAlgorithmService.java
return calculate(inputStream, algorithms); } } @Override public Map<ChecksumAlgorithm, String> calculate(InputStream stream, Collection<ChecksumAlgorithm> algorithms) throws IOException { nonNull(stream, "stream"); nonNull(algorithms, "algorithms"); LinkedHashMap<ChecksumAlgorithm, ChecksumCalculator> algMap = new LinkedHashMap<>();
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 7.4K bytes - Viewed (0) -
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 javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java
getAvailableKeyMatchList().stream().forEach(keyMatch -> { try { final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); if (logger.isDebugEnabled()) { logger.debug("Loading KeyMatch Query: {}, Size: {}", keyMatch.getQuery(), keyMatch.getMaxSize()); } getDocumentList(keyMatch).stream().map(doc -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/kuromoji/ApiAdminDictKuromojiAction.java
body.dictId = dictId; validateApi(body, messages -> {}); return kuromojiService.getKuromojiFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/mapping/ApiAdminDictMappingAction.java
body.dictId = dictId; validateApi(body, messages -> {}); return charMappingService.getCharMappingFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteProcessor.java
import com.google.errorprone.annotations.DoNotMock; import java.io.IOException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A callback interface to process bytes from a stream. * * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return * {@code false} when you want to stop processing. * * @author Chris Nokleberg * @since 1.0 */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/accesstoken/ApiAdminAccesstokenAction.java
*/ package org.codelibs.fess.app.web.api.admin.accesstoken; import static org.codelibs.core.stream.StreamUtil.stream; import static org.codelibs.fess.app.web.admin.accesstoken.AdminAccesstokenAction.getAccessToken; 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;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultRootLocator.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.internal.impl.model; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import java.io.IOException; import java.io.InputStream; import java.nio.file.Files; import java.nio.file.Path; import com.ctc.wstx.stax.WstxInputFactory;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/UpdateLabelJob.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.job; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.es.client.SearchEngineClient;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.5K bytes - Viewed (0)