- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 553 for delay (0.05 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
Preconditions.checkNotNull(command, "command must not be null"); Preconditions.checkNotNull(unit, "unit must not be null!"); return schedule(java.util.concurrent.Executors.callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
Preconditions.checkNotNull(command, "command must not be null"); Preconditions.checkNotNull(unit, "unit must not be null!"); return schedule(java.util.concurrent.Executors.callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt
fun setBodyDelay( delay: Long, unit: TimeUnit, ) = apply { bodyDelayAmount = delay bodyDelayUnit = unit } fun getBodyDelay(unit: TimeUnit): Long = unit.convert(bodyDelayAmount, bodyDelayUnit) fun setHeadersDelay( delay: Long, unit: TimeUnit, ) = apply { headersDelayAmount = delay headersDelayUnit = unit }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/deprecation/deprecation.go
for _, httpRoute := range vs.Http { if httpRoute.Fault != nil { if httpRoute.Fault.Delay != nil { // nolint: staticcheck if httpRoute.Fault.Delay.Percent > 0 { ctx.Report(gvk.VirtualService, msg.NewDeprecated(r, replacedMessage("HTTPRoute.fault.delay.percent", "HTTPRoute.fault.delay.percentage"))) } } } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 02 20:50:14 UTC 2023 - 4.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/PerCallSettings.kt
import okhttp3.Request class PerCallSettings { private val client = OkHttpClient() fun run() { val request = Request.Builder() .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. .build() // Copy to customize OkHttp for this request. val client1 = client.newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build() try {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
cluster/addons/addon-manager/kube-addons.sh
# $1 filename of addon to start. # $2 count of tries to start the addon. # $3 delay in seconds between two consecutive tries # $4 namespace function start_addon() { local -r addon_filename=$1; local -r tries=$2; local -r delay=$3; local -r namespace=$4 create_resource_from_string "$(cat "${addon_filename}")" "${tries}" "${delay}" "${addon_filename}" "${namespace}" } # $1 string with json or yaml.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 15 05:40:38 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher_test.go
}) t.Run("only user", func(t *testing.T) { cms, w := setup(t) if _, err := cms.Create(context.Background(), cmUser, metav1.CreateOptions{}); err != nil { t.Fatal(err) } retry.UntilOrFail(t, func() bool { return w.Mesh().GetIngressClass() == "user" }, retry.Delay(time.Millisecond), retry.Timeout(time.Second)) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
String message = "inputFuture=[" + localInputFuture + "]"; if (localTimer != null) { long delay = localTimer.getDelay(TimeUnit.MILLISECONDS); // Negative delays look confusing in an error message if (delay > 0) { message += ", remaining delay=[" + delay + " ms]"; } } return message; } return null; } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 7.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java
private final OkHttpClient client = new OkHttpClient(); public void run() throws Exception { Request request = new Request.Builder() .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. .build(); // Copy to customize OkHttp for this request. OkHttpClient client1 = client.newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build();
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun May 22 01:29:42 UTC 2016 - 1.9K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
func netpollBreak() {} func netpoll(delay int64) (gList, int32) { lock(&mtx) // If delay >= 0, we include a subscription of type Clock that we use as // a timeout. If delay < 0, we omit the subscription and allow poll_oneoff // to block indefinitely. pollsubs := subs if delay >= 0 { timeout := &subs[0] clock := timeout.u.subscriptionClock() clock.timeout = uint64(delay) } else { pollsubs = subs[1:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0)