Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 697 for Streams (0.03 sec)

  1. android/guava/src/com/google/common/hash/MessageDigestHashFunction.java

        private static final long serialVersionUID = 0;
      }
    
      Object writeReplace() {
        return new SerializedForm(prototype.getAlgorithm(), bytes, toString);
      }
    
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /** Hasher that updates a message digest. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/hash/PrimitiveSink.java

    import com.google.common.annotations.Beta;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.nio.ByteBuffer;
    import java.nio.charset.Charset;
    
    /**
     * An object which can receive a stream of primitive values.
     *
     * @author Kevin Bourrillion
     * @since 12.0 (in 11.0 as {@code Sink})
     */
    @Beta
    public interface PrimitiveSink {
      /**
       * Puts a byte into this sink.
       *
       * @param b a byte
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/BinaryTransformer.java

                resultData.setEncoding(responseData.getCharSet());
                return resultData;
            } catch (final IOException e) {
                throw new CrawlerSystemException("Could not convert the input stream.", e);
            }
    
        }
    
        /**
         * Retrieves data from the given AccessResultData object as a ByteArrayInputStream.
         * @param accessResultData The AccessResultData object.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/ParametricNullness.java

     * </ul>
     *
     * <p>Consumers of this annotation include:
     *
     * <ul>
     *   <li>NullAway, which <a
     *       href="https://github.com/google/guava/issues/6126#issuecomment-1204399671">treats it
     *       identically to {@code Nullable}</a> as of version 0.9.9.
     *   <li><a href="https://developers.google.com/j2objc">J2ObjC</a>, maybe: It might no longer be
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 16:20:21 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/math/ParametricNullness.java

     * </ul>
     *
     * <p>Consumers of this annotation include:
     *
     * <ul>
     *   <li>NullAway, which <a
     *       href="https://github.com/google/guava/issues/6126#issuecomment-1204399671">treats it
     *       identically to {@code Nullable}</a> as of version 0.9.9.
     *   <li><a href="https://developers.google.com/j2objc">J2ObjC</a>, maybe: It might no longer be
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 16:20:21 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/net/ParametricNullness.java

     * </ul>
     *
     * <p>Consumers of this annotation include:
     *
     * <ul>
     *   <li>NullAway, which <a
     *       href="https://github.com/google/guava/issues/6126#issuecomment-1204399671">treats it
     *       identically to {@code Nullable}</a> as of version 0.9.9.
     *   <li><a href="https://developers.google.com/j2objc">J2ObjC</a>, maybe: It might no longer be
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 16:20:21 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt

        if (showHeaders) {
          println(StatusLine.get(response))
          val headers = response.headers
          for ((name, value) in headers) {
            println("$name: $value")
          }
          println()
        }
    
        // Stream the response to the System.out as it is returned from the server.
        val out = System.out.sink()
        val source = response.body.source()
        while (!source.exhausted()) {
          out.write(source.buffer, source.buffer.size)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // TimeUnit.timedJoin() treats negative timeouts just like zero.
              NANOSECONDS.timedJoin(thread, remainingNanos);
              return;
            } catch (InterruptedException e) {
              interrupted = true;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbFileOutputStreamTest.java

                    SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC, SmbConstants.FILE_WRITE_DATA,
                    SmbConstants.DEFAULT_SHARING);
    
            // Close the stream
            outputStream.close();
    
            // When & Then - after close, tmp is null so write(int) will throw NullPointerException
            // This is the actual behavior of the implementation
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

          }
        assertFailsWith<IOException> {
          body.bytes()
        }.also { expected ->
          assertThat(expected.message).isEqualTo(
            "Content-Length (10) and stream length (5) disagree",
          )
        }
      }
    
      @Test
      fun bytesThrowsMoreThanIntMaxValue() {
        val body: ResponseBody =
          object : ResponseBody() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12.4K bytes
    - Viewed (0)
Back to top