- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for burst (0.04 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
int oneSecWorthOfWork = rate; stopwatch.sleepMillis(rate * 1000); limiter.setRate(rate); long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // we allow one second worth of work to go in a burst (i.e. take less than a second) assertThat(burst).isAtMost(1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
int oneSecWorthOfWork = rate; stopwatch.sleepMillis(rate * 1000); limiter.setRate(rate); long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // we allow one second worth of work to go in a burst (i.e. take less than a second) assertThat(burst).isAtMost(1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallLimitsTest.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import app.cash.burst.Burst import app.cash.burst.burstValues import java.io.IOException import java.util.Random import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 3.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import app.cash.burst.Burst import app.cash.burst.burstValues import assertk.assertFailure import assertk.assertThat import assertk.assertions.hasMessage import assertk.assertions.isFailure import assertk.assertions.isFalse
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 11 02:37:00 GMT 2026 - 28.8K bytes - Click Count (0) -
gradle/libs.versions.toml
binary-compatibility-validator = { id = "org.jetbrains.kotlinx.binary-compatibility-validator", version.ref = "binary-compatibility-validator" } bnd = { id = "biz.aQute.bnd", version.ref = "bnd" } burst = { id = "app.cash.burst", version.ref = "burst" } dokka = { id = "org.jetbrains.dokka", version.ref = "dokka" } graalvm = { id = "org.graalvm.buildtools.native", version.ref = "graalvm-plugin" }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 31 22:01:48 GMT 2026 - 12K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.36.md
- Client-go informers can now enqueue new watch events while already-queued events are being processed. This avoids dropping watches during a burst of incoming events due to contention on slow processing. This behavior is controlled by the UnlockWhileProcessing client-go feature gate, which is enabled by default. ([#136264](https://github.com/kubernetes/kubernetes/pull/136264), [@michaelasp](...
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Mar 19 23:38:00 GMT 2026 - 142.1K bytes - Click Count (0) -
RELEASE.md
Johannes Mayer, John Lawson, Johnson145, Jon Malmaud, Jonathan Alvarez-Gutierrez, Juang, Yi-Lin, Julian Viereck, Kaarthik Sivashanmugam, Karl Lessard, ******@****.***, Kevin Carbone, Kevin Van Der Burgt, Kongsea, ksellesk, lanhin, Lef Ioannidis, Liangliang He, Louis Tiao, Luke Iwanski, LáSzló Csomor, magixsno, Mahmoud Abuzaina, Marcel Hlopko, Mark Neumann, Maxwell Paul Brickner,
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Mon Mar 30 18:31:38 GMT 2026 - 746.5K bytes - Click Count (3)