Search Options

Results per page
Sort
Preferred Languages
Advance

Results 651 - 660 of 729 for streams (1.6 sec)

  1. src/main/java/org/codelibs/fess/helper/PermissionHelper.java

                try {
                    if (fileAttributeView instanceof final AclFileAttributeView aclFileAttributeView) {
                        aclFileAttributeView.getAcl().stream().forEach(acl -> {
                            final UserPrincipal principal = acl.principal();
                            if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/ImmutableSetTest.java

    import com.google.common.testing.EqualsTester;
    import java.util.ArrayList;
    import java.util.Collection;
    import java.util.Iterator;
    import java.util.Set;
    import java.util.function.BiPredicate;
    import java.util.stream.Collector;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit test for {@link ImmutableSet}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/dict/protwords/AdminDictProtwordsAction.java

            verifyTokenKeep(() -> downloadpage(form.dictId));
            return protwordsService.getProtwordsFile(form.dictId)
                    .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> {
                        file.writeOut(out);
                    }))
                    .orElseGet(() -> {
                        throwValidationError(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL),
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 20.1K bytes
    - Viewed (0)
  4. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedSet.java

    import java.util.Collection;
    import java.util.Collections;
    import java.util.Comparator;
    import java.util.Iterator;
    import java.util.List;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import java.util.stream.Collector;
    import org.jspecify.annotations.Nullable;
    
    /**
     * GWT emulation of {@link com.google.common.collect.ImmutableSortedSet}.
     *
     * @author Hayward Chan
     */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Aug 06 18:32:41 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  5. src/archive/tar/format.go

    	magicUSTAR, versionUSTAR = "ustar\x00", "00"
    	trailerSTAR              = "tar\x00"
    )
    
    // Size constants from various tar specifications.
    const (
    	blockSize  = 512 // Size of each block in a tar stream
    	nameSize   = 100 // Max length of the name field in USTAR format
    	prefixSize = 155 // Max length of the prefix field in USTAR format
    
    	// Max length of a special file (PAX header, GNU long name or link).
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Err != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream chunked reader with optional trailers.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream signature verifier.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  8. docs/metrics/prometheus/list.md

    | `minio_node_cpu_avg_nice_max`        | CPU nice time (max).                       |
    | `minio_node_cpu_avg_steal`           | CPU steam time.                            |
    | `minio_node_cpu_avg_steal_avg`       | CPU steam time (avg).                      |
    | `minio_node_cpu_avg_steal_max`       | CPU steam time (max).                      |
    | `minio_node_cpu_avg_load1`           | CPU load average 1min.                     |
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 43.4K bytes
    - Viewed (0)
  9. docs/es/docs/advanced/custom-response.md

    # Response Personalizado - HTML, Stream, Archivo, otros
    
    Por defecto, **FastAPI** devolverá los responses usando `JSONResponse`.
    
    Puedes sobrescribirlo devolviendo un `Response` directamente como se ve en [Devolver una Response directamente](response-directly.md){.internal-link target=_blank}.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

      /**
       * Returns the sum of all values in this map.
       *
       * <p>This method is not atomic: the sum may or may not include other concurrent operations.
       */
      public long sum() {
        return map.values().stream().mapToLong(Long::longValue).sum();
      }
    
      @LazyInit private transient @Nullable Map<K, Long> asMap;
    
      /** Returns a live, read-only view of the map backing this {@code AtomicLongMap}. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 11.7K bytes
    - Viewed (0)
Back to top