Search Options

Results per page
Sort
Preferred Languages
Advance

Results 791 - 800 of 921 for Streams (0.09 sec)

  1. 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)
  2. 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 arrays
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 22 18:14:49 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                                SmbConstants.ATTR_NORMAL, 0);
                    }
                    // one extra acquire to keep this open till the stream is released
                    return this.handle.acquire();
                }
    
            }
            log.trace("Pipe already open");
            return this.handle.acquire();
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  10. 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(
          MockResponse
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top