Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 401 - 410 of 639 for Streams (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

            stats.put("fs", getFsObj());
            return asJson(new ApiStatsResponse().stats(stats).status(ApiResult.Status.OK).result());
        }
    
        private FsObj[] getFsObj() {
            return Arrays.stream(File.listRoots()).map(f -> {
                final FsObj fsObj = new FsObj();
                fsObj.path = f.getAbsolutePath();
                fsObj.free = f.getFreeSpace();
                fsObj.total = f.getTotalSpace();
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb2/nego/PreauthIntegrityNegotiateContextTest.java

    import static org.junit.jupiter.api.Assertions.assertSame;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.util.Arrays;
    import java.util.Random;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    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;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 34K bytes
    - Click Count (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java

            }
    
            try {
                smbClient.doGet(baseUrl);
                fail();
            } catch (final ChildUrlsException e) {
                String[] urls = e.getChildUrlList().stream().map(r -> r.getUrl()).sorted().toArray(String[]::new);
                assertEquals(3, urls.length);
                assertEquals(baseUrl + "dir1/", urls[0]);
                assertEquals(baseUrl + "dir3/", urls[1]);
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Tue Sep 23 06:42:59 GMT 2025
    - 31.9K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/ImmutableAsList.java

        }
    
        @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        @Override
      Object writeReplace() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  5. 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"';
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 3K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

     */
    package org.codelibs.fess.app.web.api.admin.scheduler;
    
    import static org.codelibs.fess.app.web.admin.scheduler.AdminSchedulerAction.getScheduledJob;
    
    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.Constants;
    import org.codelibs.fess.app.pager.SchedulerPager;
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sun Nov 23 12:34:02 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.crawler.Constants;
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  8. android/guava/src/com/google/common/base/Optional.java

       * <p><b>Comparison to {@code java.util.Optional}:</b> this method has no equivalent in Java 8's
       * {@code Optional} class; use {@code
       * optionals.stream().filter(Optional::isPresent).map(Optional::get)} instead.
       *
       * <p><b>Java 9 users:</b> use {@code optionals.stream().flatMap(Optional::stream)} instead.
       *
       * @since 11.0 (generics widened in 13.0)
       */
      public static <T> Iterable<T> presentInstances(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jun 04 13:03:16 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  9. 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.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 21.4K bytes
    - Click Count (0)
  10. tensorflow/c/c_api_macros_internal.h

    // `struct_size` is used for struct member compatibility check between core TF
    // and plug-ins with the same C API minor version. More info here:
    // https://github.com/tensorflow/community/blob/master/rfcs/20200612-stream-executor-c-api/C_API_versioning_strategy.md
    #define TF_VALIDATE_STRUCT_SIZE(STRUCT_NAME, STRUCT_OBJ, SIZE_VALUE_NAME) \
      do {                                                                    \
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Mar 13 17:40:56 GMT 2023
    - 2.5K bytes
    - Click Count (0)
Back to Top