- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for read_all (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
this.callsPerHost = other.callsPerHost } val host: String get() = originalRequest.url.host val request: Request get() = originalRequest val call: RealCall get() = this@RealCall /** * Attempt to enqueue this async call on [executorService]. This will attempt to clean up * if the executor has been shut down by reporting the call as failed. */
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/internal/connection/RealConnection.kt
*/ internal var allocationLimit = 1 private set /** Current calls carried by this connection. */ val calls = mutableListOf<Reference<RealCall>>() /** Timestamp when `allocations.size()` reached zero. Also assigned upon initial connection. */ var idleAtNs = Long.MAX_VALUE /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
import okhttp3.internal.connection.CallConnectionUser import okhttp3.internal.connection.FastFallbackExchangeFinder import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase
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) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
this.uriPort = ******@****.***t } private lateinit var call: RealCall private val routeDatabase = RouteDatabase() @BeforeEach fun setUp() { call = clientTestRule.newClient().newCall( Request.Builder() .url("https://$uriHost:$uriPort/") .build(), ) as RealCall } @AfterEach fun tearDown() { factory.close() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
} user.connectionAcquired(connection) user.connectionConnectionAcquired(connection) return connection } override fun trackFailure( call: RealCall, e: IOException?, ) { // Do nothing. } override fun noNewExchanges() { // Do nothing. } override fun cancel() { canceled = true
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
import java.util.concurrent.TimeUnit import okhttp3.internal.connection.RealCall import okhttp3.internal.finishedAccessor internal class RecordingExecutor( private val dispatcherTest: DispatcherTest, ) : AbstractExecutorService() { private var shutdown: Boolean = false private val calls = mutableListOf<RealCall.AsyncCall>() override fun execute(command: Runnable) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
import okhttp3.HttpUrl import okhttp3.Protocol import okhttp3.Route import okhttp3.internal.http.RealInterceptorChain /** * A connection user that is a specific [RealCall]. */ internal class CallConnectionUser( private val call: RealCall, private val poolConnectionListener: ConnectionListener, private val chain: RealInterceptorChain, ) : ConnectionUser { private val eventListener: EventListener
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
import okhttp3.Connection import okhttp3.Interceptor import okhttp3.Request import okhttp3.Response import okhttp3.internal.checkDuration import okhttp3.internal.connection.Exchange import okhttp3.internal.connection.RealCall /** * A concrete interceptor chain that carries the entire interceptor chain: all application * interceptors, the OkHttp core, all network interceptors, and finally the network caller. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
import okhttp3.EventListener import okhttp3.Headers import okhttp3.Interceptor import okhttp3.Protocol import okhttp3.Request import okhttp3.Response import okhttp3.internal.closeQuietly import okhttp3.internal.connection.RealCall import okhttp3.internal.discard import okhttp3.internal.http.ExchangeCodec import okhttp3.internal.http.HttpMethod import okhttp3.internal.http.RealResponseBody import okhttp3.internal.http.promisesBody
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val c1 = factory.newConnection(pool, routeA1, 50L) val client = OkHttpClient.Builder() .connectionPool(poolApi) .build() val call = client.newCall(Request(addressA.url)) as RealCall call.enterNetworkInterceptorExchange(call.request(), true, factory.newChain(call)) c1.withLock { call.acquireConnectionNoEvents(c1) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0)