- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 444 for timeout (0.12 sec)
-
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) -
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) -
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) -
.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) -
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) -
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) -
src/main/java/jcifs/Configuration.java
/** * * Property <tt>jcifs.smb.client.soTimeout</tt> (int, default 35000) * * @return socket timeout, in milliseconds */ int getSoTimeout (); /** * * Property <tt>jcifs.smb.client.connTimeout</tt> (int, default 35000) * * @return timeout for establishing a socket connection, in milliseconds */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 18K bytes - Viewed (0) -
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) -
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) -
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)