Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for burst (0.05 sec)

  1. 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());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  2. 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());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  3. 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
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  4. 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
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 24.4K bytes
    - Viewed (0)
  5. 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)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 11.5K bytes
    - Viewed (1)
  6. okhttp/build.gradle.kts

    plugins {
      kotlin("multiplatform")
      id("com.android.library")
      kotlin("plugin.serialization")
      id("org.jetbrains.dokka")
      id("com.vanniktech.maven.publish.base")
      id("binary-compatibility-validator")
      id("app.cash.burst")
    }
    
    val platform = System.getProperty("okhttp.platform", "jdk9")
    val testJavaVersion = System.getProperty("test.java.version", "21").toInt()
    
    val copyKotlinTemplates = tasks.register<Copy>("copyKotlinTemplates") {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  7. 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 in
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 19.3K bytes
    - Viewed (0)
Back to top