- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 95 for delay (0.06 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
} } func (fx *Updater) WaitOrFail(t test.Failer, et string) *Event { t.Helper() delay := time.NewTimer(time.Second * 5) defer delay.Stop() for { select { case e := <-fx.Events: if e.Type == et { return &e } log.Infof("skipping event %q want %q", e.Type, et) continue case <-delay.C: t.Fatalf("timed out waiting for %v", et) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
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) -
src/runtime/netpoll_stub.go
} unlock(&netpollBrokenLock) } // Polls for ready network connections. // Returns list of goroutines that become runnable. func netpoll(delay int64) (gList, int32) { // Implementation for platforms that do not support // integrated network poller. if delay != 0 { // This lock ensures that only one goroutine tries to use // the note. It should normally be completely uncontended. lock(&netpollStubLock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt
.readTimeout(5, TimeUnit.SECONDS) .callTimeout(10, TimeUnit.SECONDS) .build() fun run() { val request = Request.Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build() client.newCall(request).execute().use { response -> println("Response completed: $response") } } } fun main() { ConfigureTimeouts().run()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay. * * Cancellation * ------------ *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
tests/integration/security/remote_jwks/remote_jwks_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.1K bytes - Viewed (0) -
.github/workflows/issue-manager.yml
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Jan 30 18:46:56 UTC 2024 - 1.1K bytes - Viewed (0) -
src/net/http/main_test.go
// checking immediately and then at exponentially increasing intervals. func waitCondition(t testing.TB, delay time.Duration, fn func(time.Duration) bool) { t.Helper() start := time.Now() var since time.Duration for !fn(since) { time.Sleep(delay) delay = 2*delay - (delay / 2) // 1.5x, rounded up since = time.Since(start) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K 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) -
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)