- Sort Score
- Result 10 results
- Languages All
Results 501 - 510 of 729 for streams (0.03 sec)
-
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.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 - 9.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/reqheader/ApiAdminReqheaderAction.java
*/ package org.codelibs.fess.app.web.api.admin.reqheader; import static org.codelibs.fess.app.web.admin.reqheader.AdminReqheaderAction.getRequestHeader; 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.ReqHeaderPager; import org.codelibs.fess.app.service.RequestHeaderService;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 9.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/webauth/ApiAdminWebauthAction.java
*/ package org.codelibs.fess.app.web.api.admin.webauth; import static org.codelibs.fess.app.web.admin.webauth.AdminWebauthAction.getWebAuthentication; 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.WebAuthPager; import org.codelibs.fess.app.service.WebAuthenticationService;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 9.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/BloomFilterTest.java
import java.io.ByteArrayOutputStream; import java.lang.Thread.UncaughtExceptionHandler; import java.math.RoundingMode; import java.util.ArrayList; import java.util.List; import java.util.Random; import java.util.stream.Stream; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Tests for SimpleGenericBloomFilter and derived BloomFilter views. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 22K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.logging.Level; import java.util.logging.Logger; import java.util.regex.MatchResult; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Stream; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing * utilities. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 21.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java
@Override protected List<String> loadDataStoreNameList() { // Return unsorted list to test sorting return List.of("Zebra", "Apple", "Banana").stream().sorted().collect(java.util.stream.Collectors.toList()); } }; List<String> names = testFactory.loadDataStoreNameList(); assertEquals(3, names.size()); assertEquals("Apple", names.get(0));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt
} @Flaky @RetryingTest(5) fun missingClientAuthFailsForNeeds() { // Fails with 11.0.1 https://github.com/square/okhttp/issues/4598 // StreamReset stream was reset: PROT... val client = buildClient(null, clientIntermediateCa.certificate) val socketFactory = buildServerSslSocketFactory() server.useHttps(socketFactory) server.requireClientAuth()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 12.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AtomicDouble.java
return get(); } /** * Saves the state to a stream (that is, serializes it). * * @serialData The current value is emitted (a {@code double}). */ private void writeObject(ObjectOutputStream s) throws IOException { s.defaultWriteObject(); s.writeDouble(get()); } /** Reconstitutes the instance from a stream (that is, deserializes it). */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java
*/ @PluginFactory public static ErrorToWarnRewritePolicy createPolicy(@PluginAttribute("loggers") final String loggerNamePrefix) { final String[] loggerNames = loggerNamePrefix != null ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n]) : new String[0]; return new ErrorToWarnRewritePolicy(loggerNames); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
/** * Get healthy channels only * * @return collection of healthy channels */ public Collection<ChannelInfo> getHealthyChannels() { return channels.values() .stream() .filter(ChannelInfo::isHealthy) .collect(ArrayList::new, (list, item) -> list.add(item), (list1, list2) -> list1.addAll(list2)); } /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0)