Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 241 for Flow (0.02 seconds)

  1. 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)
  2. 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)
  3. guava/src/com/google/common/collect/CompactLinkedHashMap.java

      }
    
      private static final int ENDPOINT = -2;
    
      /**
       * Contains the link pointers corresponding with the entries, in the range of [0, size()). The
       * high 32 bits of each long is the "prev" pointer, whereas the low 32 bits is the "succ" pointer
       * (pointing to the next entry in the linked list). The pointers in [size(), entries.length) are
       * all "null" (UNSET).
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val extraParameters: String = "",
    ) {
        PER_COMMIT(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_DAY(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_WEEK(
            displayName = "Performance Experiment",
            timeout = 420,
            channel = "experiments",
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Jan 20 03:53:25 GMT 2026
    - 27.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

    import okio.GzipSink
    import okio.Sink
    import okio.Source
    import okio.buffer
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Tag("Slow")
    class InterceptorTest {
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      @StartStop
      private val server = MockWebServer()
    
      private var client = clientTestRule.newClient()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/CompactHashSet.java

      /**
       * Contains the logical entries, in the range of [0, size()). The high bits of each int are the
       * part of the smeared hash of the element not covered by the hashtable mask, whereas the low bits
       * are the "next" pointer (pointing to the next entry in the bucket chain), which will always be
       * less than or equal to the hashtable mask.
       *
       * <pre>
       * hash  = aaaaaaaa
       * mask  = 00000fff
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 23.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/primitives/ImmutableLongArray.java

       * of values that will be added, if that knowledge is readily available. It is better to guess a
       * value slightly too high than slightly too low. If the value is not exact, the {@link
       * ImmutableLongArray} that is built will very likely occupy more memory than strictly necessary;
       * to trim memory usage, build using {@code builder.build().trimmed()}.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 12 14:49:24 GMT 2025
    - 22K bytes
    - Click Count (0)
  8. guava/src/com/google/common/base/FinalizableReferenceQueue.java

      final boolean threadStarted;
    
      /** Constructs a new queue. */
      public FinalizableReferenceQueue() {
        // We could start the finalizer lazily, but I'd rather it blow up early.
        queue = new ReferenceQueue<>();
        frqRef = new PhantomReference<>(this, queue);
        boolean threadStarted = false;
        try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 19:26:59 GMT 2026
    - 15.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/ImmutableCollection.java

     *       worse, and possibly better, than creating a mutable collection and copying it.
     *   <li>Implementations generally do not cache hash codes. If your element or key type has a slow
     *       {@code hashCode} implementation, it should cache it itself.
     * </ul>
     *
     * <h4>Example usage</h4>
     *
     * {@snippet :
     * class Foo {
     *   private static final ImmutableSet<String> RESERVED_CODES =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 21.4K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

    import okio.Socket
    import okio.buffer
    import okio.inMemorySocketPair
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    
    @Tag("Slow")
    class RealWebSocketTest {
      // NOTE: Fields are named 'client' and 'server' for cognitive simplicity. This differentiation has
      // zero effect on the behavior of the WebSocket API which is why tests are only written once
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
Back to Top