- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for finally (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
check(executed.compareAndSet(false, true)) { "Already Executed" } 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/test/java/okhttp3/internal/http/ExternalHttp2Example.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* * ## Upstream * * In this case the current thread is assigned as the upstream reader. We read bytes from * upstream and copy them to both the file and to the buffer. Finally we release the upstream * reader lock and return the new bytes. * * ## The file * * In this case we copy bytes from the file to the [sink]. * * ## The buffer *
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) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
} } assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion) } localhostInsecureRequest() } finally { Security.removeProvider("Conscrypt") client.close() } } @Test fun testRequestUsesPlayProvider() { assumeNetwork() try { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} ?: return logger.logElapsed(task, task.queue!!) { var completedNormally = false try { runTask(task) completedNormally = true } finally { // If the task is crashing start another thread to service the queues. if (!completedNormally) { lock.withLock { startAnotherThread() }
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/connection/ConnectPlan.kt
connectSocket() success = true return ConnectResult(plan = this) } catch (e: IOException) { user.connectFailed(route, null, e) return ConnectResult(plan = this, throwable = e) } finally { user.removePlanToCancel(this) if (!success) { rawSocket?.closeQuietly() } } } override fun connectTlsEtc(): ConnectResult {
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/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
skipBuffer.clear() } true // Success! The source has been exhausted. } catch (_: InterruptedIOException) { false // We ran out of time before exhausting the source. } finally { if (originalDurationNs == Long.MAX_VALUE) { timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MediaTypeJvmTest.kt
} } private fun <T> withLocale( locale: Locale, block: () -> T, ): T { val previous = Locale.getDefault() try { Locale.setDefault(locale) return block() } finally { Locale.setDefault(previous) } } @Test fun testIllegalCharsetName() { val mediaType = parse("text/plain; charset=\"!@#$%^&*()\"") assertNull(mediaType.charsetName()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/TestTls13Request.kt
.tlsVersions(TlsVersion.TLS_1_2) .build() private fun testClient( urls: List<String>, client: OkHttpClient, ) { try { for (url in urls) { sendRequest(client, url) } } finally { client.dispatcher.executorService.shutdownNow() client.connectionPool.evictAll() } } private fun buildClient(vararg specs: ConnectionSpec): OkHttpClient { return OkHttpClient.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0)