Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for Streams (0.06 sec)

  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_
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (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}.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 21:07:18 UTC 2025
    - 52.9K bytes
    - Viewed (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 {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 86.5K bytes
    - Viewed (0)
  4. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  5. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (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")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  7. 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))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 84K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

                                        StreamUtil.stream(groupsAndRoles.getFirst()).of(stream1 -> stream1.forEach(groupList::add));
                                        StreamUtil.stream(groupsAndRoles.getSecond()).of(stream2 -> stream2.forEach(roleList::add));
                                    }
                                }
                            }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 56.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java

            }
            return list.stream().map(p -> {
                final String key = p.getFirst();
                if (StringUtil.isEmpty(key) || userBean
                        .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key)))
                                || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 88.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                                }
                            });
                            final List<String> newGroupList = stream(user.getGroupNames()).get(stream -> stream.collect(Collectors.toList()));
                            stream(user.getGroupNames()).of(stream -> stream.forEach(name -> {
                                if (oldGroupList.contains(name)) {
                                    oldGroupList.remove(name);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 86.3K bytes
    - Viewed (0)
Back to top