Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for eventListenerFactory (0.13 seconds)

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

  1. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

          var socketClass: String? = null
    
          // Need fresh client to reset sslSocketFactoryOrNull
          client =
            OkHttpClient
              .Builder()
              .eventListenerFactory(
                clientTestRule.wrap(
                  object : EventListener() {
                    override fun connectionAcquired(
                      call: Call,
                      connection: Connection,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

        }
    
      fun wrap(eventRecorder: EventRecorder) = wrap(eventRecorder.eventListener)
    
      fun wrap(eventListenerFactory: EventListener.Factory) =
        EventListener.Factory { call ->
          ClientRuleEventListener(::addEvent) + eventListenerFactory.create(call)
        }
    
      /**
       * Returns an OkHttpClient for tests to use as a starting point.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

       */
      @get:JvmName("networkInterceptors")
      val networkInterceptors: List<Interceptor> =
        builder.networkInterceptors.toImmutableList()
    
      @get:JvmName("eventListenerFactory")
      val eventListenerFactory: EventListener.Factory =
        builder.eventListenerFactory
    
      @get:JvmName("retryOnConnectionFailure")
      val retryOnConnectionFailure: Boolean =
        builder.retryOnConnectionFailure
    
      @get:JvmName("fastFallback")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 51.5K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/JSSETest.kt

      }
    
      @Test
      @Disabled
      fun testFacebook() {
        val sessionIds = mutableListOf<String>()
    
        assumeNetwork()
    
        client =
          client
            .newBuilder()
            .eventListenerFactory(
              clientTestRule.wrap(
                object : EventListener() {
                  override fun connectionAcquired(
                    call: Call,
                    connection: Connection,
                  ) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

      private var eventRecorder = EventRecorder()
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
      private var client =
        clientTestRule
          .newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventRecorder))
          .build()
    
      fun executeAndCheckUpgrade(request: Request) {
        val socketHandler =
          MockSocketHandler()
            .apply {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 08 21:07:01 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
    
        client =
          clientTestRule
            .newClientBuilder()
            .eventListenerFactory(clientTestRule.wrap(eventRecorder))
            .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks.
            .dns { dnsResults }
            .fastFallback(true)
            .build()
        url =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  7. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

      val clientTestRule = OkHttpClientTestRule()
      private val eventRecorder = EventRecorder()
      private val listener = EventSourceRecorder()
      private var client =
        clientTestRule
          .newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventRecorder))
          .build()
    
      @AfterEach
      fun after() {
        listener.assertExhausted()
      }
    
      @Test
      fun event() {
        server.enqueue(
          MockResponse
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

      val eventRecorder = EventRecorder()
      var client =
        clientTestRule
          .newClientBuilder()
          .dns { throw UnknownHostException() }
          .dispatcher(dispatcher)
          .eventListenerFactory(clientTestRule.wrap(eventRecorder))
          .build()
    
      @BeforeEach
      fun setUp() {
        dispatcher.maxRequests = 20
        dispatcher.maxRequestsPerHost = 10
        eventRecorder.forbidLock(dispatcher)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        val interceptors: List<Interceptor> = client.interceptors
        val networkInterceptors: List<Interceptor> = client.networkInterceptors
        val eventListenerFactory: EventListener.Factory = client.eventListenerFactory
        val proxySelector: ProxySelector = client.proxySelector
        val cookieJar: CookieJar = client.cookieJar
        val cache: Cache? = client.cache
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 49.7K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

      }
    
      @Test
      fun webSocketsDontTriggerEventListener() {
        val eventRecorder = EventRecorder()
        client =
          client
            .newBuilder()
            .eventListenerFactory(clientTestRule.wrap(eventRecorder))
            .build()
        webServer.enqueue(
          MockResponse
            .Builder()
            .webSocketUpgrade(serverListener)
            .build(),
        )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
Back to Top