- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for burst (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 21.9K 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 Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 21.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import app.cash.burst.Burst import assertk.assertThat import assertk.assertions.containsExactly import assertk.assertions.isEmpty import assertk.assertions.isEqualTo import java.io.IOException import java.net.InetAddress
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 11.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CookieTest.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.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isFalse import assertk.assertions.isNotEqualTo import assertk.assertions.isNotNull
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 24.4K bytes - Click Count (0) -
build.gradle.kts
classpath(libs.gradlePlugin.kotlinSerialization) classpath(libs.gradlePlugin.androidJunit5) classpath(libs.gradlePlugin.android) classpath(libs.gradlePlugin.bnd) classpath(libs.gradlePlugin.burst) classpath(libs.gradlePlugin.shadow) classpath(libs.gradlePlugin.animalsniffer) classpath(libs.gradlePlugin.errorprone) classpath(libs.gradlePlugin.spotless) classpath(libs.gradlePlugin.mavenPublish)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 11.5K bytes - Click Count (1) -
cmd/local-locker.go
) // Reject new lock requests immediately when this many are queued // for the local lock mutex. // We do not block unlocking or maintenance, but they add to the count. // The limit is set to allow for bursty behavior, // but prevent requests to overload the server completely. // Rejected clients are expected to retry. const lockMutexWaitLimit = 1000
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
} @Override double coolDownIntervalMicros() { return warmupPeriodMicros / maxPermits; } } /** * This implements a "bursty" RateLimiter, where storedPermits are translated to zero throttling. * The maximum number of permits that can be saved (when the RateLimiter is unused) is defined inCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 19.3K bytes - Click Count (0)