Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for puts (0.16 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt

     * direct translation of the pseudocode presented there.
     *
     * Partner this class with [UTS #46] to implement IDNA2008 [RFC 5890] like most browsers do.
     *
     * [RFC 3492]: https://datatracker.ietf.org/doc/html/rfc3492
     * [RFC 5890]: https://datatracker.ietf.org/doc/html/rfc5890
     * [UTS #46]: https://www.unicode.org/reports/tr46/
     */
    object Punycode {
      val PREFIX_STRING = "xn--"
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 03 03:04:50 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  2. okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt

        val cookieStrings = mutableListOf<String>()
        for (cookie in cookies) {
          cookieStrings.add(cookieToString(cookie, true))
        }
        val multimap = mapOf("Set-Cookie" to cookieStrings)
        try {
          cookieHandler.put(url.toUri(), multimap)
        } catch (e: IOException) {
          Platform.get().log("Saving cookies failed for " + url.resolve("/...")!!, WARN, e)
        }
      }
    
      override fun loadForRequest(url: HttpUrl): List<Cookie> {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:10:43 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

        assertThat(recordedRequest.method).isEqualTo("PUT")
        assertThat(recordedRequest.body.readUtf8()).isEqualTo("def")
        assertThat(recordedRequest.headers["Content-Length"]).isEqualTo("3")
        assertThat(recordedRequest.headers["Content-Type"]).isEqualTo(
          "text/plain; charset=utf-8",
        )
      }
    
      @Test
      fun put_HTTPS() {
        enableTls()
        put()
      }
    
      @Test
      fun put_HTTP_2() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

            taskRunner = taskRunner,
            connectionPool = pool,
            route = route,
            socket = Socket(),
            idleAtNs = idleAtNanos,
          )
        result.withLock { pool.put(result) }
        return result
      }
    
      fun newConnectionPool(
        taskRunner: TaskRunner = this.taskRunner,
        maxIdleConnections: Int = Int.MAX_VALUE,
        routePlanner: RoutePlanner? = null,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        // 3 different lookups in the connection pool!
        val pooled3 = routePlanner.planReusePooledConnection(this, routes)
        if (pooled3 != null) return pooled3.connection
    
        connection.withLock {
          connectionPool.put(connection)
          user.acquireConnectionNoEvents(connection)
        }
    
        user.connectionAcquired(connection)
        user.connectionConnectionAcquired(connection)
        return connection
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Cache.kt

        val response = entry.response(snapshot)
        if (!entry.matches(request, response)) {
          response.body.closeQuietly()
          return null
        }
    
        return response
      }
    
      internal fun put(response: Response): CacheRequest? {
        val requestMethod = response.request.method
    
        if (HttpMethod.invalidatesCache(response.request.method)) {
          try {
            remove(response.request)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

              val editCountBefore = editCount
              yieldUntil { nanoTime >= waitUntil || editCount > editCountBefore }
            }
          }
        }
    
        override fun put(element: T) {
          taskRunner.lock.withLock {
            delegate.put(element)
            editCount++
          }
        }
    
        override fun iterator() = error("unsupported")
    
        override fun offer(e: T) = error("unsupported")
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

          if (response.promisesBody() && CacheStrategy.isCacheable(response, cacheNetworkRequest)) {
            // Offer this request to the cache.
            val cacheRequest = cache.put(response.newBuilder().request(cacheNetworkRequest).build())
            return cacheWritingResponse(cacheRequest, response).also {
              if (cacheResponse != null) {
                // This will log a conditional cache miss only.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Mar 22 07:09:21 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Request.kt

        open fun post(body: RequestBody): Builder = commonPost(body)
    
        @JvmOverloads
        open fun delete(body: RequestBody? = commonEmptyRequestBody): Builder = commonDelete(body)
    
        open fun put(body: RequestBody): Builder = commonPut(body)
    
        open fun patch(body: RequestBody): Builder = commonPatch(body)
    
        open fun method(
          method: String,
          body: RequestBody?,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:17:44 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.advanceUntil(540.ms)
        assertEvents(
          "plan 2 TCP connect canceled",
        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test puts several connections in flight that all fail at approximately the same time. It
       * confirms the fast fallback implements these invariants:
       *
       *  * if there's no TCP connect in flight, start one.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
Back to top