Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 688 for Streams (0.24 sec)

  1. android/guava/src/com/google/common/collect/Multimaps.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 86.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/math/Stats.java

    import java.io.Serializable;
    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    import java.util.Iterator;
    import java.util.Objects;
    import java.util.stream.Collector;
    import java.util.stream.DoubleStream;
    import java.util.stream.IntStream;
    import java.util.stream.LongStream;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A bundle of statistical summary values -- sum, count, mean/average, min and max, and several
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Sets.java

       *
       * <p><b>Java 8+ users:</b> many use cases for this method are better addressed by {@link
       * java.util.stream.Stream#filter}. This method is not being deprecated, but we gently encourage
       * you to migrate to streams.
       */
      // TODO(kevinb): how to omit that last sentence when building GWT javadoc?
      public static <E extends @Nullable Object> Set<E> filter(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(response1).isEqualTo("")
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Now make the second request which will restrict the first HTTP/2 connection from creating new
        // streams.
        client.newCall(request).enqueue(callback)
        val response2 = responses.take()
        assertThat(response2).isEqualTo("DEF")
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull()
      }
    
      /**
       * Reads `count` characters from the stream. If the stream is exhausted before `count`
       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
        inputStream: InputStream,
        count: Int,
      ): String {
        val result = StringBuilder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  6. docs/recipes.md

            }
          }
        ```
    
    ### Post Streaming ([.kt][PostStreamingKotlin], [.java][PostStreamingJava])
    
    Here we `POST` a request body as a stream. The content of this request body is being generated as it's being written. This example streams directly into the [Okio](https://github.com/square/okio) buffered sink. Your programs may prefer an `OutputStream`, which you can get from `BufferedSink.outputStream()`.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Lists.java

       * this reason.
       *
       * <p><b>Java 8+ users:</b> many use cases for this method are better addressed by {@link
       * java.util.stream.Stream#map}. This method is not being deprecated, but we gently encourage you
       * to migrate to streams.
       */
      public static <F extends @Nullable Object, T extends @Nullable Object> List<T> transform(
          List<F> fromList, Function<? super F, ? extends T> function) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 42.2K bytes
    - Viewed (0)
  8. CHANGELOG.md

     *  New: `mockwebserver3.SocketPolicy` is now a sealed interface. This is one of several
        backwards-incompatible API changes that may impact early adopters of this alpha API.
    
     *  New: `mockwebserver3.Stream` for duplex streams.
    
     *  New: `mockwebserver3.MockResponseBody` for streamed response bodies.
    
     *  New: `mockwebserver3.MockResponse` is now immutable, with a `Builder`.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (1)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // HEADERS STREAM 3
        peer.acceptFrame() // DATA STREAM 3 "abcde"
        peer.acceptFrame() // HEADERS STREAM 3
        peer.play()
    
        // Play it back.
        val connection = connect(peer)
        val stream = connection.newStream(headerEntries("a", "android"), true)
        stream.enqueueTrailers(headersOf("foo", "bar"))
        val sink = stream.sink.buffer()
        sink.writeUtf8("abcdefghi")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Multimaps.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 86.9K bytes
    - Viewed (0)
Back to top