- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for kwon (0.2 sec)
-
docs/features/events.md
### EventListener.Factory In the preceding example we used a field, `callStartNanos`, to track the elapsed time of each event. This is handy, but it won’t work if multiple calls are executing concurrently. To accommodate this, use a `Factory` to create a new `EventListener` instance for each `Call`. This allows each listener to keep call-specific state.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
): Relay { val randomAccessFile = RandomAccessFile(file, "rw") val result = Relay(randomAccessFile, upstream, 0L, metadata, bufferMaxSize) // Write a dirty header. That way if we crash we won't attempt to recover this. randomAccessFile.setLength(0L) result.writeHeader(PREFIX_DIRTY, -1L, -1L) return result } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
saves bandwidth but it costs CPU and memory! If you run into a problem you may need to adjust or disable the `permessage-deflate` compression settings on your server. Note that OkHttp won't use compression when sending messages smaller than 1 KiB. * Fix: Don't crash when the URL hostname contains an underscore on Android.
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/test/java/okhttp3/URLConnectionTest.kt
.build(), ) } } private fun testServerClosesOutput(socketPolicy: SocketPolicy) { server.enqueue( MockResponse( body = "This connection won't pool properly", socketPolicy = socketPolicy, ), ) val responseAfter = MockResponse(body = "This comes after a busted connection") server.enqueue(responseAfter)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* this class separates _allocations_ from _streams_. An allocation is created by a call, used for * one or more streams, and then released. An allocated connection won't be stolen by other calls * while a redirect or authorization challenge is being handled. * * When the maximum concurrent streams limit is reduced, some allocations will be rescinded.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* * ## Web Socket Lifecycle * * Upon normal operation each web socket progresses through a sequence of states: * * * **Connecting:** the initial state of each web socket. Messages may be enqueued but they won't * be transmitted until the web socket is open. * * * **Open:** the web socket has been accepted by the remote peer and is fully operational. * Messages in either direction are enqueued for immediate transmission.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
assertThat(server.takeRequest().sequenceNumber) .isEqualTo(0) // Fresh connection. assertThat(client.connectionPool.connectionCount()).isEqualTo(2) } /** * Won't coalesce if we can't clean certs e.g. a dev setup. */ @Test fun redirectWithDevSetup() { val trustManager: X509TrustManager = object : X509TrustManager { override fun checkClientTrusted(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(synStream.outFinished).isFalse() val ping = peer.takeFrame() assertThat(ping.type).isEqualTo(Http2.TYPE_PING) } /** * Test that the client sends a RST_STREAM if doing so won't disrupt the output stream. */ @Test fun clientClosesClientInputStream() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK
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) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
0EBA ; valid # 12.0 LAO SIGN PALI VIRAMA 0EBB..0EBD ; valid # 1.1 LAO VOWEL SIGN MAI KON..LAO SEMIVOWEL SIGN NYO 0EBE..0EBF ; disallowed # NA <reserved-0EBE>..<reserved-0EBF> 0EC0..0EC4 ; valid # 1.1 LAO VOWEL SIGN E..LAO VOWEL SIGN AI
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Feb 10 11:25:47 GMT 2024 - 854.1K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() } if (connectResult.isSuccess) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0)