- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for male (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* Multiple calls to this method may be made concurrently. */ @Throws(IOException::class) abstract fun onStream(stream: Http2Stream) /** * Notification that the connection's peer's settings may have changed to [settings]. * Implementations should take appropriate action to handle the updated settings. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() // Do blocking calls to plan a route for a new connection. val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from // the pool. We have a better chance of matching thanks to connection coalescing. val pooled2 = planReusePooledConnection(connect, connect.routes)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
// proxy and would manifest as a standard IOException. Unless it is one we know we should not // retry, we return true and try a new route. return true } /** * Figures out the HTTP request to make in response to receiving [userResponse]. This will * either add authentication headers, follow redirects or handle a client request timeout. If a * follow-up is either unnecessary or not applicable, this returns null. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* Okio buffers are internally implemented as a linked list of arrays. Usually this implementation * detail is invisible to the caller, but subtle use of certain APIs may depend on these internal * structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is * not terminated. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
@Throws(InterruptedException::class) fun takeRequest( timeout: Long, unit: TimeUnit, ): RecordedRequest? = requestQueue.poll(timeout, unit) /** * Scripts [response] to be returned to a request made in sequence. The first request is * served by the first enqueued response; the second request by the second enqueued response; and * so on. * * @throws ClassCastException if the default dispatcher has been
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
* * Mappings may overlap. * * ASCII-Only * ========== * * Neither the section index nor the ranges data use bit 0x80 anywhere. That means the data is * strictly ASCII. This is intended to make it efficient to encode this data as a string, and to * index into it as a string. * * The mappings data contains non-ASCII characters. */ internal class IdnaMappingTable internal constructor(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Apr 02 11:39:58 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
} servedDate != null -> { conditionName = "If-Modified-Since" conditionValue = servedDateString } else -> return CacheStrategy(request, null) // No condition! Make a regular request. } val conditionalRequestHeaders = request.headers.newBuilder() conditionalRequestHeaders.addLenient(conditionName, conditionValue!!) val conditionalRequest =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
try { val connection = exchangeFinderFactory(this, state.address, PoolConnectionUser).find() // RealRoutePlanner will add the connection to the pool itself, other RoutePlanners may not // TODO: make all RoutePlanners consistent in this behavior if (connection !in connections) { connection.withLock { put(connection) } } return 0L // run again immediately to create more connections if needed
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
.status("HTTP/1.1 200 Fantastic") transferKind.setBody(mockResponse, "I love puppies but hate spiders", 1) server.enqueue(mockResponse.build()) // Make sure that calling skip() doesn't omit bytes from the cache. val request = Request.Builder().url(server.url("/")).build() val response1 = client.newCall(request).execute() val in1 = response1.body.source()
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.play() // Play it back. val connection = connect(peer) connection.writePingAndAwaitPong() // Make sure settings have been acked. val stream = connection.newStream(headerEntries("b", "banana"), true) connection.writePingAndAwaitPong() // Make sure the window update has been received. val sink = stream.getSink() stream.writeTimeout().timeout(500, TimeUnit.MILLISECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)