Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for realCall (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

    ) : AbstractExecutorService() {
      private var shutdown: Boolean = false
      private val calls = mutableListOf<RealCall.AsyncCall>()
    
      override fun execute(command: Runnable) {
        if (shutdown) throw RejectedExecutionException()
        calls.add(command as RealCall.AsyncCall)
      }
    
      fun assertJobs(vararg expectedUrls: String) {
        val actualUrls = calls.map { it.request.url.toString() }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Oct 06 18:34:01 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

    import okhttp3.internal.concurrent.TaskQueue
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.assertLockHeld
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.connection.RealCall.CallReference
    import okhttp3.internal.okHttpName
    import okhttp3.internal.platform.Platform
    
    class RealConnectionPool internal constructor(
      taskRunner: TaskRunner,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.connection.RealConnection
    import okhttp3.internal.connection.RealConnectionPool
    import okhttp3.internal.connection.RealRoutePlanner
    import okhttp3.internal.http.RealInterceptorChain
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      private val socketConnectTimeoutMillis: Int,
      private val socketReadTimeoutMillis: Int,
      private val pingIntervalMillis: Int,
      private val retryOnConnectionFailure: Boolean,
      private val call: RealCall,
      private val routePlanner: RealRoutePlanner,
      // Specifics to this plan.
      override val route: Route,
      internal val routes: List<Route>?,
      private val attempt: Int,
      private val tunnelRequest: Request?,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 19.3K bytes
    - Click Count (2)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

    import okhttp3.Cache
    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
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/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) }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/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()
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

     * IP address, and TLS mode. Connections may also be recycled.
     */
    class RouteSelector internal constructor(
      private val address: Address,
      private val routeDatabase: RouteDatabase,
      private val call: RealCall,
      private val fastFallback: Boolean,
    ) {
      // State for negotiating the next proxy to use.
      private var proxies = emptyList<Proxy>()
      private var nextProxyIndex: Int = 0
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 7.3K bytes
    - Click Count (2)
  9. okhttp/src/commonJvmAndroid/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
    
      /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

    import okio.buffer
    
    /**
     * Transmits a single HTTP request and a response pair. This layers connection management and events
     * on [ExchangeCodec], which handles the actual I/O.
     */
    class Exchange(
      internal val call: RealCall,
      internal val finder: ExchangeFinder,
      private val codec: ExchangeCodec,
    ) {
      /** True if the request body need not complete before the response body starts. */
      internal var isDuplex: Boolean = false
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 10.5K bytes
    - Click Count (0)
Back to Top