- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Cool (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
* of which connections to keep open for future use. * * @constructor Create a new connection pool with tuning parameters appropriate for a single-user * application. The tuning parameters in this pool are subject to change in future OkHttp releases. * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of * inactivity. */ class ConnectionPool internal constructor(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
expectedEvents += "ResponseBodyEnd" expectedEvents += "ConnectionReleased" expectedEvents += "CallEnd" assertThat(listener.recordedEventTypes()).isEqualTo(expectedEvents) // Confirm that the connection pool was not corrupted by making another call. makeSimpleCall() } /** * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttp.kt
* * Note that OkHttp's runtime version may be different from the version specified in your * project's build file due to the dependency resolution features of your build tool. * * [semver]: https://semver.org */ @Suppress("MayBeConstant") // Non-const so external callers get the runtime version. @JvmField val VERSION = CONST_VERSION
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.6K bytes - Viewed (1) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
var uriPort: Int = 1 fun newConnection( pool: RealConnectionPool, route: Route, idleAtNanos: Long = Long.MAX_VALUE, taskRunner: TaskRunner = this.taskRunner, ): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* simulate late connection pool failures. */ object DisconnectAfterRequest : SocketPolicy /** * Half close connection (InputStream for client) after reading the request but before * writing the response. Use this to simulate late connection pool failures. */ object HalfCloseAfterRequest : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
// We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() } if (connectResult.isSuccess) { return connectResult.plan.handleSuccess()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false var yieldBeforePlanReturns = false
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/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* 1. If the current call already has a connection that can satisfy the request it is used. Using * the same connection for an initial exchange and its follow-ups may improve locality. * * 2. If there is a connection in the pool that can satisfy the request it is used. Note that it is * possible for shared exchanges to make requests to different host names! See * [RealConnection.isEligible] for details. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
import okhttp3.Connection import okhttp3.Handshake import okhttp3.HttpUrl import okhttp3.Protocol import okhttp3.Route /** * The object that is asking for a connection. Either a call or a connect policy from the pool. */ interface ConnectionUser { fun addPlanToCancel(connectPlan: ConnectPlan) fun removePlanToCancel(connectPlan: ConnectPlan) fun updateRouteDatabaseAfterSuccess(route: Route)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/PoolConnectionUser.kt
import java.net.Proxy import java.net.Socket import okhttp3.Connection import okhttp3.Handshake import okhttp3.HttpUrl import okhttp3.Protocol import okhttp3.Route /** * A user that is a connection pool creating connections in the background * without an intent to immediately use them. */ object PoolConnectionUser : ConnectionUser { override fun addPlanToCancel(connectPlan: ConnectPlan) { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 2.6K bytes - Viewed (0)