- Sort Score
- Result 10 results
- Languages All
Results 911 - 920 of 1,027 for jstream (0.06 sec)
-
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
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) -
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) -
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) -
docs/metrics/prometheus/list.md
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 43.4K bytes - Viewed (0) -
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) -
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) -
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. */ @JvmFieldRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 10.9K bytes - Viewed (0) -
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) -
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)