Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 204 for Flow (0.28 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
      }
    
      @Tag("Slow")
      @Test
      fun successfulExpectContinuePermitsConnectionReuseWithHttp2() {
        enableProtocol(Protocol.HTTP_2)
        successfulExpectContinuePermitsConnectionReuse()
      }
    
      @Tag("Slow")
      @Test
      fun unsuccessfulExpectContinuePreventsConnectionReuse() {
        server.enqueue(MockResponse())
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/CompactHashing.java

      /** Use high bits of metadata for modification count. */
      static final int MODIFICATION_COUNT_INCREMENT = 1 << HASH_TABLE_BITS_MAX_BITS;
    
      /** Bitmask that selects the low bits of metadata to get hashTableBits. */
      static final int HASH_TABLE_BITS_MASK = (1 << HASH_TABLE_BITS_MAX_BITS) - 1;
    
      /** Maximum size of a compact hash-based collection (2^30 - 1 because 0 is UNSET). */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

             * problems can exist with methods like FutureTask.done(), not to mention slow calls to
             * Thread.interrupt() (as discussed in InterruptibleTask). At the end of the day, it's
             * unlikely that cancel() will be slow, so we can probably get away with calling it while
             * holding a lock. Still, it would be nice to avoid somehow.
             */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      /** True if this connect was canceled; typically because it lost a race. */
      @Volatile private var canceled = false
    
      // These properties are initialized by connect() and never reassigned.
    
      /** The low-level TCP socket. */
      private var rawSocket: JavaNetSocket? = null
    
      /**
       * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
       * itself if this connection does not use SSL.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  5. android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java

        assertThrows(
            UnsupportedOperationException.class,
            () -> rangeSet.removeAll(ImmutableRangeSet.of(Range.closed(6, 8))));
      }
    
      @AndroidIncompatible // slow
      public void testExhaustive() {
        ImmutableSet<Range<Integer>> ranges =
            ImmutableSet.of(
                Range.<Integer>all(),
                Range.<Integer>closedOpen(3, 5),
                Range.singleton(1),
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 25 16:19:30 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/IterablesTest.java

        List<String> list = ImmutableList.of("a", "b");
        Iterator<String> iterator = skip(list, 2).iterator();
        assertThrows(UnsupportedOperationException.class, () -> iterator.remove());
      }
    
      @GwtIncompatible // slow (~35s)
      public void testSkip_iterator() {
        new IteratorTester<Integer>(
            5, MODIFIABLE, newArrayList(2, 3), IteratorTester.KnownOrder.KNOWN_ORDER) {
          @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 47.5K bytes
    - Click Count (0)
  7. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

        try {
          constructor = type.getConstructor();
        } catch (NoSuchMethodException e) {
          return arbitraryConstantInstanceOrNull(type);
        }
        constructor.setAccessible(true); // accessibility check is too slow
        try {
          return constructor.newInstance();
        } catch (InstantiationException | IllegalAccessException impossible) {
          throw new AssertionError(impossible);
        } catch (InvocationTargetException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 21.4K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/google/SortedMultisetTestSuiteBuilder.java

            .withFeatures(features)
            .suppressing(parentBuilder.getSuppressedTests())
            .createTestSuite();
      }
    
      /**
       * Returns an array of four bogus elements that will always be too high or too low for the
       * display. This includes two values for each extreme.
       *
       * <p>This method (dangerously) assume that the strings {@code "!! a"} and {@code "~~ z"} will
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Flaky
    @Tag("Slow")
    class WebSocketHttpTest {
      // Flaky https://github.com/square/okhttp/issues/4515
      // Flaky https://github.com/square/okhttp/issues/4953
      @RegisterExtension
      var clientTestRule = configureClientTestRule()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/primitives/DoublesTest.java

                    }
                  }
                }
              }
            }
          }
        }
      }
    
      @AndroidIncompatible // slow
      @GwtIncompatible // Doubles.tryParse
      public void testTryParseAllCodePoints() {
        // Exercise non-ASCII digit test cases and the like.
        char[] tmp = new char[2];
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 01:43:32 GMT 2026
    - 30.9K bytes
    - Click Count (0)
Back to Top