Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 33 for bursty (0.23 seconds)

  1. 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)
  2. 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  3. 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 5.9K bytes
    - Click Count (1)
  4. src/main/webapp/WEB-INF/orig/view/error/busy.jsp

    Shinsuke Sugaya <******@****.***> 1771833824 +0900
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 1.4K bytes
    - Click Count (0)
  5. src/main/webapp/WEB-INF/view/error/busy.jsp

    Shinsuke Sugaya <******@****.***> 1770697442 +0900
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Tue Feb 10 04:24:02 GMT 2026
    - 1.4K bytes
    - Click Count (0)
  6. build.gradle.kts

      alias(libs.plugins.android.junit5) apply false
      alias(libs.plugins.shadow) apply false
      alias(libs.plugins.graalvm) apply false
      alias(libs.plugins.ksp) apply false
      alias(libs.plugins.burst) apply false
      id("okhttp.dokka-multimodule-conventions")
    }
    
    tasks.wrapper {
      distributionType = Wrapper.DistributionType.ALL
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 839 bytes
    - Click Count (1)
  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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  8. internal/bucket/bandwidth/reader.go

    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return n, err
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    	need := len(buf)         // number of bytes requested by caller
    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  9. src/main/resources/fess_indices/fess/tr/stopwords.txt

    acaba
    altmış
    altı
    ama
    ancak
    arada
    aslında
    ayrıca
    bana
    bazı
    belki
    ben
    benden
    beni
    benim
    beri
    beş
    bile
    bin
    bir
    birçok
    biri
    birkaç
    birkez
    birşey
    birşeyi
    biz
    bize
    bizden
    bizi
    bizim
    böyle
    böylece
    bu
    buna
    bunda
    bundan
    bunlar
    bunları
    bunların
    bunu
    bunun
    burada
    çok
    çünkü
    da
    daha
    dahi
    de
    defa
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 19 06:31:02 GMT 2018
    - 1.5K bytes
    - Click Count (0)
  10. cmd/listen-notification-handlers.go

    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top