Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for Streams (0.05 seconds)

  1. docs/changelogs/changelog_3x.md

    
    ## Version 3.14.5
    
    _2020-01-03_
    
     *  Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact
        the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after
        a stream timeout to determine whether the connection should remain eligible for pooling.
    
    
    ## Version 3.14.4
    
    _2019-09-29_
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ImmutableSortedMap.java

    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link NavigableMap} whose contents will never change, with many other important properties
     * detailed at {@link ImmutableCollection}.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 52.9K bytes
    - Click Count (0)
  3. 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 {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 86.5K bytes
    - Click Count (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)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 67.4K bytes
    - Click Count (0)
  5. 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(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 81.6K bytes
    - Click Count (0)
  6. 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")
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

    import java.util.ServiceLoader;
    import java.util.Set;
    import java.util.function.Consumer;
    import java.util.function.UnaryOperator;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Stream;
    
    import com.google.inject.AbstractModule;
    import org.apache.commons.cli.CommandLine;
    import org.apache.commons.cli.Option;
    import org.apache.commons.cli.ParseException;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 78.1K bytes
    - Click Count (0)
  8. cmd/peer-rest-server.go

    	cleanupUploadIDCacheMetaRPC    = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerClearUploadID, grid.NewMSS, grid.NewNoPayload)
    
    	// STREAMS
    	// Set an output capacity of 100 for consoleLog and listenRPC
    	// There is another buffer that will buffer events.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  9. cmd/xl-storage-format-v2.go

    				merged = append(merged, latest)
    
    				// Calculate latest 'n' non-free versions.
    				if !latest.header.FreeVersion() {
    					nVersions++
    				}
    			}
    		}
    
    		// Remove from all streams up until latest modtime or if selected.
    		for i, vers := range versions {
    			for _, ver := range vers {
    				// Truncate later modtimes, not selected.
    				if ver.header.ModTime > latest.header.ModTime {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  10. CHANGELOG/CHANGELOG-1.3.md

    * GCI: Update the command to get the image ([#24987](https://github.com/kubernetes/kubernetes/pull/24987), [@andyzheng0831](https://github.com/andyzheng0831))
    * Port-forward: use out and error streams instead of glog ([#17030](https://github.com/kubernetes/kubernetes/pull/17030), [@csrwng](https://github.com/csrwng))
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 84K bytes
    - Click Count (0)
Back to Top