Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 417 for timeouts (0.08 sec)

  1. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires.
       * If the timeout expires, not only will the output future finish, but also the input future
       * ({@code this}) will be cancelled and interrupted.
       *
       * @param timeout when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. .teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt

        os: Os = Os.LINUX,
        arch: Arch = Arch.AMD64,
        extraParameters: String = "",
        timeout: Int = 90,
        daemon: Boolean = true,
        buildJvm: Jvm = BuildToolBuildJvm,
        extraSteps: BuildSteps.() -> Unit = {}
    ) {
        buildType.applyDefaultSettings(os, timeout = timeout, buildJvm = buildJvm)
    
        buildType.killProcessStep(KILL_LEAKED_PROCESSES_FROM_PREVIOUS_BUILDS, os)
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Sep 24 06:22:49 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      }
    
      /**
       * Waits for the all the services to reach a terminal state for no more than the given time. After
       * this method returns all services will either be {@linkplain Service.State#TERMINATED
       * terminated} or {@linkplain Service.State#FAILED failed}.
       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ServiceManager.java

       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
       * @throws TimeoutException if not all of the services have stopped within the deadline
       */
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public void awaitStopped(long timeout, TimeUnit unit) throws TimeoutException {
        state.awaitStopped(timeout, unit);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt

      override fun cancel(): Unit = error("unexpected")
    
      override fun isExecuted(): Boolean = error("unexpected")
    
      override fun isCanceled(): Boolean = error("unexpected")
    
      override fun timeout(): Timeout = error("unexpected")
    
      override fun clone(): Call = error("unexpected")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Service.java

       */
      default void awaitRunning(Duration timeout) throws TimeoutException {
        awaitRunning(toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  9. .teamcity/src/main/kotlin/common/performance-test-extensions.kt

    import jetbrains.buildServer.configs.kotlin.buildSteps.script
    
    fun BuildType.applyPerformanceTestSettings(os: Os = Os.LINUX, arch: Arch = Arch.AMD64, timeout: Int = 30) {
        applyDefaultSettings(os = os, arch = arch, timeout = timeout)
        artifactRules = """
            build/report-*-performance-tests.zip => .
            build/report-*-performance.zip => $hiddenArtifactDestination
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Jun 03 03:39:03 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/DuplexTest.kt

            .url(server.url("/"))
            .post(AsyncRequestBody())
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertTrue(call.isCanceled())
        }
      }
    
      @Test
      fun fullCallTimeoutDoesNotApplyOnceConnected() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
Back to top