Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 771 for Streams (0.29 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/log/ApiAdminLogAction.java

        }
    
        /**
         * Downloads a specific log file by ID.
         *
         * @param id the base64-encoded filename of the log file to download
         * @return stream response containing the log file content
         */
        // GET /api/admin/log/file/{id}
        @Execute
        public StreamResponse get$file(final String id) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. guava/src/com/google/common/hash/HashingOutputStream.java

       * unspecified if this method is called more than once on the same instance.
       */
      public HashCode hash() {
        return hasher.hash();
      }
    
      // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
      // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.
      // It should flush itself if necessary.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

            // Verify format - should contain "Thread:" entries
            boolean hasThreadEntry = capturedOutput.stream().anyMatch(line -> line.startsWith("Thread:"));
            assertTrue("Should contain Thread: entries", hasThreadEntry);
    
            // Verify format - should contain stack trace entries
            boolean hasStackTrace = capturedOutput.stream().anyMatch(line -> line.startsWith("\tat "));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbEnumerationUtilTest.java

    import java.lang.reflect.Constructor;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.net.URL;
    import java.net.UnknownHostException;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    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
    - 17.1K bytes
    - Viewed (0)
  10. docs/bucket/versioning/DESIGN.md

    `xl.meta` carries first 8 bytes an XL header which describes the current format and the format version,
    allowing the unmarshaller's to automatically use the right data structures to parse the subsequent content in the stream.
    
    ### v1.0
    
    | Entry     | Encoding    | Content
    | ----------|-------------|----------------------------------------
    | xlHeader  | [4]byte     | `'X', 'L', '2', ' '`
    | xlVersion | [4]byte     | `'1', ' ', ' ', ' '`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
Back to top