- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for finish (0.22 sec)
-
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/main/kotlin/okhttp3/HttpUrl.kt
val c = this[i] if (c == '\\' || c == '/') { slashCount++ } else { break } } return slashCount } /** Finds the first ':' in `input`, skipping characters between square braces "[...]". */ private fun portColonOffset( input: String, pos: Int, limit: Int, ): Int { var i = pos
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K 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) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K 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) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
snapshot2.assertValue(1, "a") } } } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun `remove while reading creates zombie that is removed when read finishes`(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) val afterRemoveFileContents = if (windows) "a" else null set("k1", "a", "a") cache["k1"]!!.use { snapshot1 ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/logging/LoggingUtil.kt
activeLogger.addHandler(handler) } if (sslDebug) { val activeLogger = getLogger("javax.net.ssl") activeLogger.level = Level.FINEST handler.level = Level.FINEST handler.formatter = MessageFormatter activeLogger.addHandler(handler) } } } } fun getLogger(name: String): Logger {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.7K bytes - Viewed (1)