- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 679 for asStream (0.11 sec)
-
src/main/java/org/codelibs/core/io/ClassTraversalUtil.java
handler.processClass(packageName, shortClassName); } } } /** * Traverses classes contained in a ZIP file input stream. * * @param zipInputStream the ZIP file input stream (must not be {@literal null}) * @param handler the handler to process classes (must not be {@literal null}) */
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/BaseThumbnailGenerator.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 13.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java
} } /** * Reloads the synonym dictionary from an input stream. * * @param updater An optional updater to apply changes. * @param in The input stream to read the dictionary from. * @throws DictionaryException if the input stream cannot be parsed. */ protected void reload(final SynonymUpdater updater, final InputStream in) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 15.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
if ("debug".equalsIgnoreCase(logLevel)) { cmdList.add("-Dorg.apache.tika.service.error.warn=true"); } } stream(fessConfig.getJvmCrawlerOptionsAsArray()) .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(value -> cmdList.add(value))); File ownTmpDir = null; final String tmpDir = System.getProperty("java.io.tmpdir");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java
*/ package org.codelibs.fess.timer; import java.io.ByteArrayOutputStream; import java.io.OutputStream; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; import org.apache.commons.text.StringEscapeUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7.8K bytes - Viewed (0) -
src/test/java/jcifs/smb1/util/LogStreamTest.java
private int originalLevel; @BeforeEach void setUp() throws Exception { // Save original state originalErr = System.err; originalLevel = LogStream.level; // Create test stream testOutput = new ByteArrayOutputStream(); testStream = new PrintStream(testOutput); // Reset LogStream instance using reflection resetLogStreamInstance(); } @AfterEach
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/MultiInputStream.java
import java.io.IOException; import java.io.InputStream; import java.util.Iterator; import org.jspecify.annotations.Nullable; /** * An {@link InputStream} that concatenates multiple substreams. At most one stream will be open at * a time. * * @author Chris Nokleberg * @since 1.0 */ @J2ktIncompatible @GwtIncompatible final class MultiInputStream extends InputStream {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed May 14 19:40:47 UTC 2025 - 2.8K bytes - Viewed (0) -
src/test/java/jcifs/smb1/UniAddressTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.stream.Stream; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbRenewableCredentialsTest.java
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; import java.util.function.Supplier; import java.util.stream.Stream; import javax.security.auth.Subject; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/nt/NtTransNotifyChangeTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.atLeastOnce; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import java.util.stream.Stream; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.4K bytes - Viewed (0)