- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 33 for bursty (0.23 seconds)
-
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/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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)