- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,033 for STREAM (0.22 sec)
-
src/main/java/jcifs/pac/kerberos/KerberosToken.java
byte[] content; try ( ASN1InputStream stream = new ASN1InputStream(token) ) { content = ASN1Util.readUnparsedTagged(0, 0x8000, stream); }catch ( IOException e ) { throw new PACDecodingException("Malformed kerberos token", e); } try ( ASN1InputStream stream = new ASN1InputStream(content) ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Oct 02 12:02:06 UTC 2023 - 3K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/resource/CompressedResourceIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Sep 14 12:12:47 UTC 2016 - 1.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/backup/ApiAdminBackupAction.java
final FessConfig fessConfig = ComponentUtil.getFessConfig(); if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) { if ("system.properties".equals(id)) { return asStream(id).contentTypeOctetStream().stream(out -> { try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/internal-instrumentation-processor/src/main/java/org/gradle/internal/instrumentation/processor/codegen/groovy/CodeGeneratingSignatureTreeVisitor.java
boolean hasCallerClassName = hasCallerClassName(request.getInterceptedCallable()); Stream<CodeBlock> maybeZeroForKotlinDefault = hasKotlinDefaultMask ? Stream.of(CodeBlock.of("0")) : Stream.empty(); Stream<CodeBlock> maybeCallerClassName = hasCallerClassName ? Stream.of(CodeBlock.of("consumer")) : Stream.empty();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:40 UTC 2024 - 8.9K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
/** * Copies all bytes from the input stream to the output stream. Does not close or flush either * stream. * * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the * equivalent {@link InputStream#transferTo} method instead. * * @param from the input stream to read from * @param to the output stream to write to * @return the number of bytes copied
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
src/test/java/org/codelibs/core/stream/StreamUtilTest.java
}); } public void test_ofNull() { assertEquals(0, (int) StreamUtil.stream().get(s -> s.toArray().length)); Object[] o = {}; assertEquals(0, (int) StreamUtil.stream(o).get(s -> s.toArray().length)); Map<Object, Object> map = new HashMap<Object, Object>(); assertEquals(0, (int) StreamUtil.stream(map).get(s -> s.toArray().length)); } public void test_ofMap() {
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/sink/AnsiConsoleUtil.java
*/ static OutputStream wrapOutputStream(final OutputStream stream) { try { return wrapOutputStream(stream, STDOUT_FILENO); } catch (Throwable ignore) { return wrapOutputStream(stream, 0); } } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 6K bytes - Viewed (0) -
guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
} /** In-memory stream-based implementation of Hasher. */ private final class BufferingHasher extends AbstractHasher { final ExposedByteArrayOutputStream stream; BufferingHasher(int expectedInputSize) { this.stream = new ExposedByteArrayOutputStream(expectedInputSize); } @Override public Hasher putByte(byte b) { stream.write(b); return this; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 3.8K bytes - Viewed (0) -
subprojects/diagnostics/src/main/java/org/gradle/api/tasks/diagnostics/internal/AggregateMultiProjectTaskReportModel.java
this.mergeTasksWithSameName = mergeTasksWithSameName; this.detail = detail; this.groupsOfInterest = Stream.concat(isNullOrEmpty(group) ? Stream.empty() : Stream.of(group), groups.stream()) .map(String::toLowerCase) .collect(Collectors.toList()); } public void add(TaskReportModel project) { projects.add(project);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 09:45:59 UTC 2024 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/QueryFieldConfig.java
*/ package org.codelibs.fess.query; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.function.Consumer; import java.util.stream.Stream; import javax.annotation.PostConstruct;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.9K bytes - Viewed (0)