- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for whale (0.33 sec)
-
docs/changelogs/changelog_4x.md
* Fix: Include the header `Accept: text/event-stream` for SSE calls. This header is not added if the request already contains an `Accept` header. * Fix: Don't crash with a `NullPointerException` if a server sends a close while we're sending a ping. OkHttp had a race condition bug. ## Version 4.6.0 _2020-04-28_ * Fix: Follow HTTP 307 and 308 redirects on methods other than GET and POST. We're reluctant 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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* .build(); * ``` * * ## Force a Cache Response * * Sometimes you'll want to show resources if they are available immediately, but not otherwise. * This can be used so your application can show *something* while waiting for the latest data to be * downloaded. To restrict a request to locally-cached resources, add the `only-if-cached` * directive: * * ```java * Request request = new Request.Builder()
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// Make an SSL Tunnel on the first message pair of each SSL + proxy connection. val url = route.address.url val requestLine = "CONNECT ${url.toHostHeader(includeDefaultPort = true)} HTTP/1.1" while (true) { val source = this.source!! val sink = this.sink!! val tunnelCodec = Http1ExchangeCodec( // No client for CONNECT tunnels: client = null,
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) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: *
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) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
private val readyQueues = mutableListOf<TaskQueue>() private val runnable: Runnable = object : Runnable { override fun run() { var incrementedRunCallCount = false while (true) { val task = ******@****.***ck { if (!incrementedRunCallCount) { incrementedRunCallCount = true runCallCount++ }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
sink.close() } } @Throws(IOException::class) private fun writeContinuationFrames( streamId: Int, byteCount: Long, ) { var byteCount = byteCount while (byteCount > 0L) { val length = minOf(maxFrameSize.toLong(), byteCount) byteCount -= length frameHeader( streamId = streamId, length = length.toInt(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
routePlanner.autoGeneratePlans = true val address = routePlanner.address val pool = routePlanner.pool // Add a connection to the pool that won't expire for a while routePlanner.defaultConnectionIdleAtNanos = expireLater setPolicy(pool, address, ConnectionPool.AddressPolicy(1)) assertThat(pool.connectionCount()).isEqualTo(1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
clientListener.assertOpen() // Send messages until the client's outgoing buffer overflows! val message: ByteString = ByteString.of(*ByteArray(1024 * 1024)) var messageCount: Long = 0 while (true) { val success = webSocket.send(message) if (!success) break messageCount++ val queueSize = webSocket.queueSize() assertThat(queueSize).isBetween(0L, messageCount * message.size)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
if (byteCount == 0L) { writer.data(outFinished, streamId, buffer, 0) return } var byteCount = byteCount while (byteCount > 0L) { var toWrite: Int this.withLock { try { while (writeBytesTotal >= writeBytesMaximum) { // Before blocking, confirm that the stream we're writing is still open. It's possible
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/http/RetryAndFollowUpInterceptor.kt
var request = chain.request val call = realChain.call var followUpCount = 0 var priorResponse: Response? = null var newRoutePlanner = true var recoveredFailures = listOf<IOException>() while (true) { call.enterNetworkInterceptorExchange(request, newRoutePlanner, chain) var response: Response var closeActiveExchange = true try { if (call.isCanceled()) {
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)