Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 47 of 47 for connectionPool (0.07 seconds)

  1. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

          builder.eventListenerFactory(LoggingEventListener.Factory(logger))
        }
        return builder.build()
      }
    
      fun close() {
        val okHttpClient = client as OkHttpClient
        okHttpClient.connectionPool.evictAll() // Close any persistent connections.
        okHttpClient.dispatcher.executorService.shutdownNow()
      }
    
      companion object {
        internal const val NAME = "okcurl"
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 6K bytes
    - Click Count (0)
  2. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

            Thread.sleep(1000)
            sendTestRequest(twitterRequest)
            Thread.sleep(1000)
            sendTestRequest(googleRequest)
            Thread.sleep(2000)
          }
        } finally {
          client.connectionPool.evictAll()
          client.dispatcher.executorService.shutdownNow()
    
          if (launch == CommandLine) {
            process?.destroyForcibly()
          }
        }
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt

          )
        val response1 = call1.execute()
        assertThat(response1.body.string()).isEqualTo("abc")
        response1.close()
    
        // Force a fresh connection for the next request.
        client.connectionPool.evictAll()
    
        // Confirm that a second request also succeeds. This should detect caching problems.
        server.enqueue(
          MockResponse
            .Builder()
            .body("def")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 24.4K bytes
    - Click Count (2)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        val call1 = client.newCall(Request(server.url("/")))
        val response = call1.execute()
        call1.cancel()
    
        // That connection is pooled, and it works.
        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
        val call2 = client.newCall(Request(server.url("/")))
        val response2 = call2.execute()
        assertThat(response2.body.string()).isEqualTo("def")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

          }.build()
      private var socksProxy: SocksProxy? = null
      private var cache: Cache? = null
    
      @BeforeEach
      fun setUp() {
        platform.assumeNotOpenJSSE()
        eventRecorder.forbidLock(get(client.connectionPool))
        eventRecorder.forbidLock(client.dispatcher)
      }
    
      @AfterEach
      fun tearDown() {
        if (socksProxy != null) {
          socksProxy!!.shutdown()
        }
        if (cache != null) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  6. CHANGELOG.md

     *  New: `HttpLoggingInterceptor.redactQueryParams()` configures the query parameters to redact
        in logs. For best security, don't put sensitive information in query parameters.
    
     *  New: `ConnectionPool.setPolicy()` configures a minimum connection pool size for a target
        address. Use this to proactively open HTTP connections.
    
        Connections opened to fulfill this policy are subject to the connection pool's
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 15 11:57:47 GMT 2026
    - 36.2K bytes
    - Click Count (2)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

            .build(),
        )
        assertThat(get(server.url("/")).body.string()).isEqualTo("A")
        assertThat(get(server.url("/")).body.string()).isEqualTo("A")
        assertThat(client.connectionPool.idleConnectionCount()).isEqualTo(1)
      }
    
      @Test
      fun expiresDateBeforeModifiedDate() {
        assertConditionallyCached(
          MockResponse
            .Builder()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
Back to Top