- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 850 for Stream (0.1 sec)
-
android/guava/src/com/google/common/collect/ImmutableBiMap.java
import java.util.Arrays; import java.util.Collection; import java.util.Comparator; import java.util.Map; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collector; import java.util.stream.Collectors; import org.jspecify.annotations.Nullable; /** * A {@link BiMap} whose contents will never change, with many other important properties detailed * at {@link ImmutableCollection}. *Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 22.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/fileauth/ApiAdminFileauthAction.java
*/ package org.codelibs.fess.app.web.api.admin.fileauth; import static org.codelibs.fess.app.web.admin.fileauth.AdminFileauthAction.getFileAuthentication; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.FileAuthPager; import org.codelibs.fess.app.service.FileAuthenticationService;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 9.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/AbstractXmlExtractor.java
*/ protected ExtractData createExtractData(final String content) { return new ExtractData(extractString(content)); } /** * Detects the encoding of the input stream. * @param bis The buffered input stream. * @return The detected encoding. */ protected String getEncoding(final BufferedInputStream bis) { final byte[] b = new byte[preloadSizeForCharset]; try {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 8.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java
// Verify the cached files have correct names List<DirectoryCacheEntry.FileInfo> children = cacheEntry.getChildren(); assertTrue(children.stream().anyMatch(f -> "file1.txt".equals(f.getName()))); assertTrue(children.stream().anyMatch(f -> "dir1".equals(f.getName()))); } @Test public void testUpdateDirectoryCache() throws IOException { String directoryPath = "/test/dir";Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 15.9K bytes - Viewed (0) -
docs/resiliency/nginx.conf
worker_processes auto; error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 4096; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"';Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Dec 21 04:24:45 UTC 2024 - 3K bytes - Viewed (0) -
CHANGELOG.md
receiving stream to process it. This change may increase OkHttp's memory use for applications that make many concurrent HTTP calls and that can receive data faster than they can process it. Previously, OkHttp limited HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB of unacknowledged data per stream and no per-connection limit.Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 19:32:33 UTC 2025 - 31.6K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
return; } if (logger.isDebugEnabled()) { try { ManagementFactory.getRuntimeMXBean().getInputArguments().stream().forEach(s -> logger.debug("Parameter: {}", s)); System.getProperties().entrySet().stream().forEach(e -> logger.debug("Property: {}={}", e.getKey(), e.getValue()));Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 11K bytes - Viewed (0) -
compat/maven-builder-support/src/main/java/org/apache/maven/building/StringSource.java
} @Override public String getLocation() { return location; } /** * Gets the content of this source. * * @return The underlying character stream, never {@code null}. */ public String getContent() { return content; } @Override public String toString() { return getLocation(); } @OverrideRegistered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jan 15 18:51:29 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosTicket.java
throw new PACDecodingException("Empty kerberos ticket"); } ASN1Sequence sequence; try { try (ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token))) { sequence = ASN1Util.as(ASN1Sequence.class, stream); } } catch (IOException e) { throw new PACDecodingException("Malformed kerberos ticket", e); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6.7K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/SimpleLookup.java
private final List<Object> objects; public SimpleLookup(List<Object> objects) { this.objects = objects; } @Override public <T> T lookup(Class<T> type) { return objects.stream() .filter(type::isInstance) .map(type::cast) .findAny() .orElseThrow(() -> new LookupException("No service of type " + type)); } @Override
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2K bytes - Viewed (0)