- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for throttle (0.16 sec)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
fail<Any>() } catch (expected: IOException) { } server.url("/b").toUrl().openConnection().getInputStream() // Should succeed. } /** * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this * should yield one sleep for a total delay of 500ms. */ @Test fun throttleRequest() { assumeNotWindows()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0) -
docs/contribute/concurrency.md
Framing rules make it impractical to implement http/2 correctly on a single blocking thread. The flow-control features introduce feedback between reads and writes, requiring writes to acknowledge reads and reads to throttle writes. In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work. ### Threads #### Application's calling thread
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } /** * Test to ensure we don't throw a read timeout on responses that are progressing. For this * case, we take a 4KiB body and throttle it to 1KiB/second. We set the read timeout to two * seconds. If our implementation is acting correctly, it will not throw, as it is progressing. */ @ParameterizedTest
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
call.cancel() assertFailsWith<IOException> { // Reading 'B' may succeed if it's buffered. inputStream.read() // But 'C' shouldn't be buffered (the response is throttled) and this should fail. inputStream.read() } inputStream.close() } @Test fun disconnectDuringConnect_cookieJar() { val callReference = AtomicReference<Call>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
server.enqueue(MockResponse(body = "B")) val inputStream = server.url("/a").toUrl().openConnection().getInputStream() assertThat(inputStream!!.read()).isEqualTo('B'.code) } /** * Throttle the request body by sleeping 500ms after every 3 bytes. With a 6-byte request, this * should yield one sleep for a total delay of 500ms. */ @Test fun throttleRequest() { assumeNotWindows()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
* limitations under the License. * */ package mockwebserver3.internal import okio.Buffer import okio.Sink /** * A sink that sleeps [periodDelayNanos] every [bytesPerPeriod] bytes. Unlike [okio.Throttler], * this permits any interval to be used. */ internal class ThrottledSink( private val delegate: Sink, private val bytesPerPeriod: Long, private val periodDelayNanos: Long, ) : Sink by delegate {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} /** Sets the socket policy and returns this. */ fun socketPolicy(socketPolicy: SocketPolicy) = apply { this.socketPolicy = socketPolicy } /** * Throttles the request reader and response writer to sleep for the given period after each * series of [bytesPerPeriod] bytes are transferred. Use this to simulate network behavior. */ fun throttleBody(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* be received. The default implementation returns an empty response. Mischievous implementations * can return other values to test HTTP edge cases, such as unhappy socket policies or throttled * request bodies. */ open fun peek(): MockResponse { return MockResponse(socketPolicy = KeepOpen) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.7K bytes - Viewed (0)