Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 100 for timeouts (0.04 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        FUTURE(Timeout.SMALL, Timeout.MAX),
        SMALL(Timeout.SMALL),
        FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL),
        INFINITE(Timeout.LARGE, Timeout.MAX);
    
        final ImmutableList<Timeout> timeouts;
    
        TimeoutsToUse(Timeout... timeouts) {
          this.timeouts = ImmutableList.copyOf(timeouts);
        }
      }
    
      /** Possible outcomes of calling any of the methods under test. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // Future treats negative timeouts just like zero.
              return future.get(remainingNanos, NANOSECONDS);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  3. docs/changelogs/changelog_2x.md

    ## Version 2.5.0
    
    _2015-08-25_
    
     *  **Timeouts now default to 10 seconds.** Previously we defaulted to never
        timing out, and that was a lousy policy. If establishing a connection,
        reading the next byte from a connection, or writing the next byte to a
        connection takes more than 10 seconds to complete, you’ll need to adjust
        the timeouts manually.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

          throw InterruptedIOException()
        }
      }
    
      /**
       * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close
       * the stream (asynchronously) which will notify the waiting thread.
       */
      internal inner class StreamTimeout : AsyncTimeout() {
        override fun timedOut() {
          closeLater(ErrorCode.CANCEL)
          connection.sendDegradedPingLater()
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      })
      @ParametricNullness
      final V blockingGet(long timeout, TimeUnit unit)
          throws InterruptedException, TimeoutException, ExecutionException {
        // NOTE: if timeout < 0, remainingNanos will be < 0 and we will fall into the while(true) loop
        // at the bottom and throw a timeoutexception.
        long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      })
      @ParametricNullness
      final V blockingGet(long timeout, TimeUnit unit)
          throws InterruptedException, TimeoutException, ExecutionException {
        // NOTE: if timeout < 0, remainingNanos will be < 0 and we will fall into the while(true) loop
        // at the bottom and throw a timeoutexception.
        long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

        val call = client.newCall(request1)
        assertFailsWith<IllegalStateException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message)
            .isEqualTo("Timeouts can't be adjusted in a network interceptor")
        }
      }
    
      @Test
      fun networkInterceptorCannotChangeWriteTimeout() {
        addInterceptor(true) { chain: Interceptor.Chain ->
          chain
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  8. docs/recipes.md

            }
          }
        ```
    
    ### Timeouts ([.kt][ConfigureTimeoutsKotlin], [.java][ConfigureTimeoutsJava])
    
    Use timeouts to fail a call when its peer is unreachable. Network partitions can be due to client connectivity problems, server availability problems, or anything between. OkHttp supports connect, write, read, and full call timeouts.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

            return bytesRead
          } finally {
            synchronized(this@Relay) {
              upstreamReader = null
              ******@****.***All()
            }
          }
        }
    
        override fun timeout(): Timeout = timeout
    
        @Throws(IOException::class)
        override fun close() {
          if (fileOperator == null) return // Already closed.
          fileOperator = null
    
          var fileToClose: RandomAccessFile? = null
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 17:15:47 UTC 2025
    - 11.8K bytes
    - Viewed (0)
Back to top