- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Finished (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
timeout.enter() callStart() try { client.dispatcher.executed(this) return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } } override fun enqueue(responseCallback: Callback) { check(executed.compareAndSet(false, true)) { "Already Executed" } callStart()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
) { lock.assertNotHeld() var remainingByteCount = byteCount while (remainingByteCount > 0L) { val finished: Boolean val flowControlError: Boolean ******@****.***ck { finished = this.finished flowControlError = remainingByteCount + readBuffer.size > maxByteCount }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
/** Used by [AsyncCall.run] to signal completion. */ internal fun finished(call: AsyncCall) { call.callsPerHost.decrementAndGet() finished(runningAsyncCalls, call) } /** Used by [Call.execute] to signal completion. */ internal fun finished(call: RealCall) { finished(runningSyncCalls, call) } private fun <T> finished( calls: Deque<T>, call: T, ) {
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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/MessageInflater.kt
// Instead, we ensure that all bytes from source have been processed by inflater. do { inflaterSource.readOrInflate(buffer, Long.MAX_VALUE) } while (inflater.bytesRead < totalBytesToRead && !inflater.finished()) } @Throws(IOException::class) override fun close() = inflaterSource.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.8K bytes - Viewed (0) -
buildSrc/src/main/kotlin/Osgi.kt
jarTask, ) bundleExtension.run { setClasspath(osgi.compileClasspath + sourceSets["main"].compileClasspath) bnd(*bndProperties) } // Call the convention when the task has finished, to modify the jar to contain OSGi metadata. jarTask.doLast { bundleExtension.buildAction().execute(this) } } val Project.sourceSets: SourceSetContainer
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 2.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
// Consuming ServerHelloDone handshake message // Produced ECDHE ClientKeyExchange handshake message // Produced client Finished handshake message // Consuming server Finished handshake message // Produced ClientHello handshake message // // Raw write // Raw read // Plaintext before ENCRYPTION
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
kotlin-js-store/yarn.lock
on-finished@2.4.1: version "2.4.1" resolved "https://registry.yarnpkg.com/on-finished/-/on-finished-2.4.1.tgz#58c8c44116e54845ad57f14ab10b03533184ac3f" integrity sha512-oVlzkg3ENAhCk2zdv7IJwd/QUD4z2RxRwpkcGY8psCVcCYZNq4wYnVWALHM+brtuJjePWiYF/ClmuDr8Ch5+kg== dependencies: ee-first "1.1.1" on-finished@~2.3.0: version "2.3.0"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* ... // Handle the failure. * } * }); * ``` * * These examples will not work if you're consuming the response body on another thread. In such * cases the consuming thread must call [close] when it has finished reading the response * body. * * ### The response body can be consumed only once. * * This class may be used to stream very large responses. For example, it is possible to use this
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() client.listener.assertClosing(1000, "Goodbye!") client.webSocket!!.finishReader() assertThat(client.closed).isTrue() // Server and client both finished closing, connection is closed. server.listener.assertClosed(1000, "Hello!") client.listener.assertClosed(1000, "Goodbye!") } @Test fun clientCloseCancelsConnectionAfterTimeout() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0)