Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for remark (6.11 sec)

  1. docs/changelogs/changelog_4x.md

        the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after
        a stream timeout to determine whether the connection should remain eligible for pooling.
    
     *  Fix: Don't call `EventListener.responseHeadersStart()` or `responseBodyStart()` until bytes have
        been received. Previously these events were incorrectly sent too early, when OkHttp was ready to
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt

        proxySelector.proxies.add(proxyA)
        proxySelector.proxies.add(proxyB)
        var routeSelector = newRouteSelector(address)
        dns[PROXY_A_HOST] = dns.allocate(1)
        dns[PROXY_B_HOST] = dns.allocate(1)
    
        // Mark the ProxyA route as failed.
        val selection = routeSelector.next()
        dns.assertRequests(PROXY_A_HOST)
        val route = selection.next()
        assertRoute(route, address, proxyA, dns.lookup(PROXY_A_HOST, 0), PROXY_A_PORT)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  3. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

            assertThat(logs[index++])
              .matches(Regex(prefix.pattern + regex.pattern, RegexOption.DOT_MATCHES_ALL))
          }
    
        fun assertNoMoreLogs() {
          assertThat(logs.size, "More messages remain: ${logs.subList(index, logs.size)}")
            .isEqualTo(index)
        }
    
        override fun log(message: String) {
          logs.add(message)
        }
      }
    
      companion object {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 09:14:38 GMT 2024
    - 37.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       * waiting for the running calls to complete.
       *
       * If more than [maxRequests] requests are in flight when this is invoked, those requests will
       * remain in flight.
       */
      var maxRequests = 64
        get() = this.withLock { field }
        set(maxRequests) {
          require(maxRequests >= 1) { "max < 1: $maxRequests" }
          this.withLock {
            field = maxRequests
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

     *     .build();
     * Response response = eagerClient.newCall(request).execute();
     * ```
     *
     * ## Shutdown Isn't Necessary
     *
     * The threads and connections that are held will be released automatically if they remain idle. But
     * if you are writing a application that needs to aggressively release unused resources you may do
     * so.
     *
     * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:21:33 GMT 2024
    - 52K bytes
    - Viewed (0)
  6. CHANGELOG.md

        `MockWebServer` and the `UPGRADE_TO_SSL_AT_END` socket option. (Only APIs on `mockwebserver3`
        are changed; the old `okhttp3.mockwebserver` APIs remain as they always have been.
    
    
    ## Version 5.0.0-alpha.7
    
    _2022-04-26_
    
    **This release introduces new Kotlin-friendly APIs.** When we migrated OkHttp from Java to Kotlin in
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:31:39 GMT 2024
    - 21.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/CacheTest.kt

        server.enqueue(
          MockResponse.Builder()
            .body("a")
            .build(),
        )
        val url = server.url("/a")
        assertThat(get(url).body.string()).isEqualTo("a")
    
        // The URL will remain available if hasNext() returned true...
        val i = cache.urls()
        assertThat(i.hasNext()).isTrue()
    
        // ...so even when we evict the element, we still get something back.
        cache.evictAll()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 108.6K bytes
    - Viewed (0)
Back to top