Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for CallStart (1.06 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       *
       * This will be invoked only once for a single [Call]. Retries of different routes or redirects
       * will be handled within the boundaries of a single [callStart] and [callEnd]/[callFailed] pair.
       */
      open fun callStart(call: Call) {
      }
    
      /**
       * Invoked prior to a proxy selection.
       *
       * This will be invoked for route selection regardless of whether the client
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        timeout.enter()
        callStart()
        try {
          client.dispatcher.executed(this)
          return getResponseWithInterceptorChain()
        } finally {
          client.dispatcher.finished(this)
        }
      }
    
      override fun enqueue(responseCallback: Callback) {
        check(executed.compareAndSet(false, true)) { "Already Executed" }
    
        callStart()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        dispatcher.maxRequests = 2 // Trigger promotion.
        callback.await(request2.url).assertFailure(InterruptedIOException::class.java)
        assertThat(listener.recordedEventTypes())
          .containsExactly("CallStart", "CallStart", "CallFailed")
      }
    
      @Test
      fun executionRejectedAfterMaxRequestsPerHostChange() {
        val request1 = newRequest("http://a/1")
        val request2 = newRequest("http://a/2")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  4. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

            .build(),
        )
        val response = client.newCall(request().build()).execute()
        assertThat(response.body).isNotNull()
        response.body.bytes()
        logRecorder
          .assertLogMatch(Regex("""callStart: Request\{method=GET, url=$url\}"""))
          .assertLogMatch(Regex("""proxySelectStart: $url"""))
          .assertLogMatch(Regex("""proxySelectEnd: \[DIRECT]"""))
          .assertLogMatch(Regex("""dnsStart: ${url.host}"""))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

          mutableListOf<String>().apply {
            add("CallStart")
            if (connectionType != H2) {
              addAll(listOf("ConnectStart", "ConnectEnd"))
            }
            addAll(listOf("ConnectionAcquired", "ConnectionReleased", "CallEnd"))
          }
    
        assertThat(events2).isEqualTo(expectedEvents2)
      }
    
      private fun isConnectionEvent(it: CallEvent?) =
        it is CallStart ||
          it is CallEnd ||
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
        // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
        // ResponseFailed, ConnectionReleased, CallFailed
        // JDK 8
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  7. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        assertEquals(
          listOf(
            "CallStart",
            "ProxySelectStart",
            "ProxySelectEnd",
            "DnsStart",
            "DnsEnd",
            "ConnectStart",
            "SecureConnectStart",
            "SecureConnectEnd",
            "ConnectEnd",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

          requestBody.writeUtf8("request A\n")
          requestBody.close()
        }
        body.awaitSuccess()
        assertThat(listener.recordedEventTypes()).containsExactly(
          "CallStart",
          "ProxySelectStart",
          "ProxySelectEnd",
          "DnsStart",
          "DnsEnd",
          "ConnectStart",
          "SecureConnectStart",
          "SecureConnectEnd",
          "ConnectEnd",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        var dns: Dns = Dns { TODO() }
    
        val system: Dns = Dns.SYSTEM
      }
    
      @Test
      fun eventListener() {
        val eventListener =
          object : EventListener() {
            override fun callStart(call: Call) = TODO()
    
            override fun dnsStart(
              call: Call,
              domainName: String,
            ) = TODO()
    
            override fun dnsEnd(
              call: Call,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 46.5K bytes
    - Viewed (0)
Back to top