Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 679 for asStream (0.11 sec)

  1. 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)
  2. src/main/java/org/codelibs/fess/thumbnail/impl/BaseThumbnailGenerator.java

                if (path != null) {
                    stream(path.split(File.pathSeparator)).of(stream -> stream.map(String::trim).forEach(s -> pathList.add(s)));
                }
                if (logger.isDebugEnabled()) {
                    logger.debug("search paths: {}", pathList);
                }
                available = generatorList.stream().map(s -> {
                    if (s.startsWith("${path}")) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top