- Sort Score
- Result 10 results
- Languages All
Results 791 - 800 of 921 for Streams (0.06 sec)
-
compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java
Model parent = getModel(baseName + "-parent"); Model child = getModel(baseName + "-child"); if (fromRepo) { // when model is read from repo, a stream is used, then pomFile == null // (has consequences in inheritance algorithm since getProjectDirectory() returns null) parent = parent.clone(); parent.setPomFile(null);
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Sep 17 10:01:14 UTC 2025 - 8.2K bytes - Viewed (0) -
guava/src/com/google/common/primitives/Floats.java
* compares, using {@link #compare(float, float)}), the first pair of values that follow any * common prefix, or when one array is a prefix of the other, treats the shorter array as the * lesser. For example, {@code [] < [1.0f] < [1.0f, 2.0f] < [2.0f]}. * * <p>The returned comparator is inconsistent with {@link Object#equals(Object)} (since arraysRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 22 18:14:49 UTC 2025 - 25.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java
responseData.addMetaData(FILE_ATTRIBUTE_VIEW, aclFileAttributeView); responseData.addMetaData(FS_FILE_GROUPS, aclFileAttributeView.getAcl().stream().map(acl -> acl.principal().getName()).toArray(n -> new String[n])); return aclFileAttributeView; }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 12:19:14 UTC 2025 - 15.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/synonym/AdminDictSynonymAction.java
}); } /** * Downloads the synonym dictionary file. * * @param form the download form containing download parameters * @return ActionResponse with the file download stream */ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) { validate(form, messages -> {}, () -> downloadpage(form.dictId));Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 23.7K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/RegularContiguousSet.java
@J2ktIncompatible @Override Object writeReplace() { return new SerializedForm<>(range, domain); } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use SerializedForm"); } @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
try { val byteRead = inputStream.read() // OpenJDK behavior: end of stream. assertThat(byteRead).isEqualTo(-1) } catch (e: ProtocolException) { // On Android, HttpURLConnection is implemented by OkHttp v2. OkHttp // treats an incomplete response body as a ProtocolException. } catch (ioe: IOException) {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Aug 03 22:38:00 UTC 2025 - 28K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateRequest.java
ciphers.add(EncryptionNegotiateContext.CIPHER_AES128_GCM); ciphers.add(EncryptionNegotiateContext.CIPHER_AES128_CCM); int[] cipherArray = ciphers.stream().mapToInt(Integer::intValue).toArray(); negoContexts.add(new EncryptionNegotiateContext(config, cipherArray)); } // Add compression context for SMB3 compression support
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 9.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
// If this succeeds, too many requests were made. executeSynchronously("/") .assertFailure(IOException::class.java) .assertFailureMatches( "stream was reset: CANCEL", "unexpected end of stream on " + server.url("/").redact(), ) } @RetryingTest(5) @Flaky fun recoverWhenRetryOnConnectionFailureIsFalse_HTTP2() { enableProtocol(Protocol.HTTP_2)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 147.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeHandleImpl.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 10.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
// Confirm that the connection pool was not corrupted by making another call. makeSimpleCall() } /** * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset. * Attempts to write the request body fails fast. */ @Test fun serverTruncatesRequestHttp2OnDuplexRequest() { enableProtocol(Protocol.HTTP_2) server.enqueue( MockResponseRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 10.4K bytes - Viewed (0)