Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for bursty (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.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.isNotEmpty
    import assertk.assertions.isNotNull
    import java.io.IOException
    import java.net.InetAddress
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.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.containsExactlyInAnyOrder
    import assertk.assertions.isEmpty
    import assertk.assertions.isNotEmpty
    import javax.net.ssl.SSLSocket
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 5.9K bytes
    - Viewed (1)
  6. 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)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.http
    
    import app.cash.burst.Burst
    import assertk.assertThat
    import assertk.assertions.contains
    import assertk.assertions.doesNotContain
    import assertk.assertions.isEqualTo
    import assertk.assertions.startsWith
    import assertk.fail
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.3.md

    * Change default value of deleting-pods-burst to 1 ([#27606](https://github.com/kubernetes/kubernetes/pull/27606), [@gmarek](https://github.com/gmarek))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 84K bytes
    - Viewed (0)
  9. 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)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.http2
    
    import app.cash.burst.Burst
    import app.cash.burst.burstValues
    import assertk.assertThat
    import assertk.assertions.contains
    import assertk.assertions.hasMessage
    import assertk.assertions.isCloseTo
    import assertk.assertions.isEqualTo
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
Back to top