Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for eventListenerFactory (0.25 sec)

  1. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

      private lateinit var url: HttpUrl
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        client =
          clientTestRule.newClientBuilder()
            .eventListenerFactory(loggingEventListenerFactory)
            .sslSocketFactory(
              handshakeCertificates.sslSocketFactory(),
              handshakeCertificates.trustManager,
            )
            .retryOnConnectionFailure(false)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  2. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Response
    
    /**
     * An OkHttp EventListener, which logs call events. Can be applied as an
     * [event listener factory][OkHttpClient.eventListenerFactory].
     *
     * The format of the logs created by this class should not be considered stable and may change
     * slightly between releases. If you need a stable logging format, use your own event listener.
     */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 11:07:32 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/SessionReuseTest.kt

                  this.enableSessionCreation = false
                }
              }
            }
          }
    
        client =
          client.newBuilder()
            .connectionSpecs(listOf(spec))
            .eventListenerFactory(
              clientTestRule.wrap(
                object : EventListener() {
                  override fun connectionAcquired(
                    call: Call,
                    connection: Connection,
                  ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 6K bytes
    - Viewed (0)
  4. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

      val clientTestRule = OkHttpClientTestRule()
      private val eventListener = RecordingEventListener()
      private val listener = EventSourceRecorder()
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventListener))
          .build()
    
      @BeforeEach
      fun before(server: MockWebServer) {
        this.server = server
      }
    
      @AfterEach
      fun after() {
        listener.assertExhausted()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 6.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
    
        client =
          clientTestRule.newClientBuilder()
            .eventListenerFactory(clientTestRule.wrap(listener))
            .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks.
            .dns { dnsResults }
            .fastFallback(true)
            .build()
        url =
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

        socketFactory = SpecificHostSocketFactory(InetSocketAddress(server.hostName, server.port))
    
        client =
          clientTestRule.newClientBuilder()
            .dns(dns)
            .socketFactory(socketFactory)
            .eventListenerFactory(clientTestRule.wrap(listener))
            .build()
      }
    
      @Test
      fun http2OneBadHostOneGoodNoRetryOnConnectionFailure() {
        enableProtocol(Protocol.HTTP_2)
    
        val request = Request(server1.url("/"))
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/DispatcherTest.kt

      val dispatcher = Dispatcher(executor)
      val listener = RecordingEventListener()
      var client =
        clientTestRule.newClientBuilder()
          .dns { throw UnknownHostException() }
          .dispatcher(dispatcher)
          .eventListenerFactory(clientTestRule.wrap(listener))
          .build()
    
      @BeforeEach
      fun setUp() {
        dispatcher.maxRequests = 20
        dispatcher.maxRequestsPerHost = 10
        listener.forbidLock(dispatcher)
      }
    
      @Test
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Apr 05 03:30:42 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  8. okhttp/src/test/java/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
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 46.5K bytes
    - Viewed (4)
  9. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                connection.set(chain!!.connection())
                chain.proceed(chain.request())
              },
            )
            .eventListenerFactory(clientTestRule.wrap(listener1))
            .build()
        val request = Request.Builder().url(sanUrl).build()
        val call1 = client1.newCall(request)
        call1.enqueue(
          object : Callback {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/DuplexTest.kt

      private var listener = RecordingEventListener()
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(listener))
          .build()
      private val executorService = Executors.newScheduledThreadPool(1)
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 23.9K bytes
    - Viewed (0)
Back to top