- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Field (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
var connection: RealConnection? = null private set private var timeoutEarlyExit = false /** * This is the same value as [exchange], but scoped to the execution of the network interceptors. * The [exchange] field is assigned to null when its streams end, which may be before or after the * network interceptors return. */ internal var interceptorScopedExchange: Exchange? = null private set
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
* remain in flight. */ var maxRequests = 64 get() = this.withLock { field } set(maxRequests) { require(maxRequests >= 1) { "max < 1: $maxRequests" } this.withLock { field = maxRequests } promoteAndExecute() } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
If you want this update with the old behavior use [this interceptor][legacy_interceptor]. * Fix: Don't crash decompressing web sockets messages. We had a bug where we assumed deflated bytes in would always yield deflated bytes out and this isn't always the case! * Fix: Reliably update and invalidate the disk cache on windows. As originally designed our
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
class AddressState( val address: Address, val queue: TaskQueue, var policy: ConnectionPool.AddressPolicy, ) { /** * How many calls the pool can carry without opening new connections. This field must only be * accessed by the connection closer task. */ var concurrentCallCapacity: Int = 0 } companion object {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
* near-simultaneously) then this is the first reason known to this peer. */ internal var errorCode: ErrorCode? = null get() = this.withLock { field } /** The exception that explains [errorCode]. Null if no exception was provided. */ internal var errorException: IOException? = null init { if (headers != null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
CHANGELOG.md
parameter only, like `request.tag<MyTagClass>()`. * New: MockWebServer has improved support for HTTP/1xx responses. Once you've migrated to the new `mockwebserver3` package, there's a new field, `MockResponse.informationalResponses`. * Fix: Don't interpret trailers as headers after an HTTP/100 response. This was a bug only when the HTTP response body itself is empty.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
if (builder.client) { set(Settings.INITIAL_WINDOW_SIZE, OKHTTP_CLIENT_WINDOW_SIZE) } } /** * Settings we receive from the peer. Changes to the field are guarded by this. The instance is * never mutated once it has been assigned. */ var peerSettings = DEFAULT_SETTINGS /** The bytes consumed and acknowledged by the application. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
taskRunner: TaskRunner, nanos: Long, ) { taskRunner.assertThreadHoldsLock() check(waitingCoordinatorTask == null) if (nanos == 0L) return // Yield until notified, interrupted, or the duration elapses. val waitUntil = nanoTime + nanos val self = currentTask waitingCoordinatorTask = self waitingCoordinatorNotified = false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
*/ @Test fun reusePlanAndNewConnectRace() { val plan0 = routePlanner.addPlan() plan0.tcpConnectDelayNanos = 250.ms plan0.yieldBeforeTcpConnectReturns = true // Yield so we get a chance to take plan1... val plan1 = routePlanner.addPlan() plan1.connectState = TLS_CONNECTED plan1.yieldBeforePlanReturns = true // ... but let plan 0 connect before we act upon it.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0)