Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 314 for Flow (0.02 sec)

  1. .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",
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Sun Aug 03 22:40:28 UTC 2025
    - 25.9K bytes
    - Viewed (0)
  2. 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.
             */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/hash/BloomFilterStrategies.java

        boolean set(long bitIndex) {
          if (get(bitIndex)) {
            return false;
          }
    
          int longIndex = (int) (bitIndex >>> LONG_ADDRESSABLE_BITS);
          long mask = 1L << bitIndex; // only cares about low 6 bits of bitIndex
    
          long oldValue;
          long newValue;
          do {
            oldValue = data.get(longIndex);
            newValue = oldValue | mask;
            if (oldValue == newValue) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb1/smb1/AndXServerMessageBlockTest.java

            assertEquals((byte) 0xFF, buf[1], "AndX command should be 0xFF when no chaining");
            assertEquals((byte) 0x00, buf[2], "Reserved byte must be 0");
            assertEquals((byte) 0xDE, buf[3], "Sentinel low offset when no chaining");
            assertEquals((byte) 0xDE, buf[4], "Sentinel high offset when no chaining");
            assertNull(block.andx, "andx should be cleared when not chaining");
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. 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.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

     * by holding a lock on the connection.
     */
    class RealConnection internal constructor(
      val taskRunner: TaskRunner,
      val connectionPool: RealConnectionPool,
      override val route: Route,
      /** The low-level TCP socket. */
      private val rawSocket: JavaNetSocket,
      /**
       * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
       * itself if this connection does not use SSL.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  7. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.runner.Description
    import org.junit.runners.model.Statement
    
    @Suppress("deprecation")
    @Timeout(30)
    @Tag("Slow")
    class MockWebServerTest {
      @RegisterExtension
      var platform = PlatformRule()
      private val server = MockWebServer()
    
      @BeforeEach
      fun setUp() {
        server.start()
      }
    
      @AfterEach
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  8. android/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) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  9. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  10. okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt

    02EE          ; valid                                  # 3.0  MODIFIER LETTER DOUBLE APOSTROPHE
    02EF..02FF    ; valid                  ;      ; NV8    # 4.0  MODIFIER LETTER LOW DOWN ARROWHEAD..MODIFIER LETTER LOW LEFT ARROW
    0300..033F    ; valid                                  # 1.1  COMBINING GRAVE ACCENT..COMBINING DOUBLE OVERLINE
    0340          ; mapped                 ; 0300          # 1.1  COMBINING GRAVE TONE MARK
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Feb 10 11:25:47 UTC 2024
    - 854.1K bytes
    - Viewed (0)
Back to top