Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for propagate (0.09 sec)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

      // A note on memory visibility.
      // Many of the utilities in this class (transform, withFallback, withTimeout, asList, combine)
      // have two requirements that significantly complicate their design.
      // 1. Cancellation should propagate from the returned future to the input future(s).
      // 2. The returned futures shouldn't unnecessarily 'pin' their inputs after completion.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Futures.java

      // A note on memory visibility.
      // Many of the utilities in this class (transform, withFallback, withTimeout, asList, combine)
      // have two requirements that significantly complicate their design.
      // 1. Cancellation should propagate from the returned future to the input future(s).
      // 2. The returned futures shouldn't unnecessarily 'pin' their inputs after completion.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/cache/CacheBuilder.java

       * operation at some <i>undefined</i> point in the future.
       *
       * <p><b>Warning:</b> any exception thrown by {@code listener} will <i>not</i> be propagated to
       * the {@code Cache} user, only logged via a {@link Logger}.
       *
       * @return the cache builder reference that should be used instead of {@code this} for any
       *     remaining configuration and cache building
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

          ).build()
        val call1 = localClient.newCall(Request(server.url("/")))
        val response1 = call1.execute()
        assertThat(response1.body.string()).isEqualTo("ABC")
    
        // Add delays for DISCONNECT_AT_END to propogate
        waitForConnectionShutdown(connections[0])
        val call2 = localClient.newCall(Request(server.url("/")))
        val response2 = call2.execute()
        assertThat(response2.body.string()).isEqualTo("DEF")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/cache/CacheBuilder.java

       * operation at some <i>undefined</i> point in the future.
       *
       * <p><b>Warning:</b> any exception thrown by {@code listener} will <i>not</i> be propagated to
       * the {@code Cache} user, only logged via a {@link Logger}.
       *
       * @return the cache builder reference that should be used instead of {@code this} for any
       *     remaining configuration and cache building
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top