Search Options

Results per page
Sort
Preferred Languages
Advance

Results 911 - 920 of 1,027 for jstream (0.06 sec)

  1. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

            if (count <= 0 || leases.isEmpty()) {
                return;
            }
    
            // Find oldest leases by last access time
            leases.entrySet()
                    .stream()
                    .sorted((e1, e2) -> Long.compare(e1.getValue().getLastAccessTime(), e2.getValue().getLastAccessTime()))
                    .limit(count)
                    .forEach(entry -> {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  2. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Aug 06 18:32:41 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // PutObject - creates an object upon reading from the input stream
    // until EOF, erasure codes the data across all disk and additionally
    // writes `xl.meta` which carries the necessary metadata for future
    // object operations.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt

    fun Closeable.closeQuietly() {
      try {
        close()
      } catch (rethrown: RuntimeException) {
        throw rethrown
      } catch (_: Exception) {
      }
    }
    
    /**
     * Returns true if file streams can be manipulated independently of their paths. This is typically
     * true for systems like Mac, Unix, and Linux that use inodes in their file system interface. It is
     * typically false on Windows.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  5. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 43.4K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

                fail();
            } catch (final ChildUrlsException e) {
                final Set<RequestData> urlSet = e.getChildUrlList();
                assertEquals(5, urlSet.size());
                final List<String> urlList = urlSet.stream().map(x -> x.getUrl()).sorted().toList();
                assertEquals("ftp://localhost:10021/dir1", urlList.get(0));
                assertEquals("ftp://localhost:10021/dir2", urlList.get(1));
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  7. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartBody.kt

         */
        @JvmField
        val PARALLEL = "multipart/parallel".toMediaType()
    
        /**
         * The media-type multipart/form-data follows the rules of all multipart MIME data streams as
         * outlined in RFC 2046. In forms, there are a series of fields to be supplied by the user who
         * fills out the form. Each field has a name. Within a given form, the names are unique.
         */
        @JvmField
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/suggest/entity/SuggestItemTest.java

            assertTrue(dest.contains("existing"));
            assertTrue(dest.contains("new1"));
            assertTrue(dest.contains("new2"));
            // Should not have duplicate "existing"
            assertEquals(1, dest.stream().filter(s -> s.equals("existing")).count());
        }
    
        @Test
        public void testConcatKinds() {
            // Test static concatKinds method
            SuggestItem.Kind[] kinds1 = { SuggestItem.Kind.QUERY };
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbRandomAccessFileTest.java

            ArgumentCaptor<Integer> lenCap = ArgumentCaptor.forClass(Integer.class);
            verify(raf, atLeast(2)).write(any(byte[].class), anyInt(), lenCap.capture());
            assertTrue(lenCap.getAllValues().stream().allMatch(len -> len == 1));
        }
    
        @Test
        @DisplayName("write(short/char/int/long/float/double): correct byte lengths")
        void write_multiByteVariants_lengths() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
Back to top