- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for cleanup (0.23 sec)
-
okhttp-urlconnection/build.gradle.kts
id("org.jetbrains.dokka") id("com.vanniktech.maven.publish.base") id("binary-compatibility-validator") } project.applyOsgi( "Fragment-Host: com.squareup.okhttp3; bundle-version=\"\${range;[==,+);\${version_cleanup;${projects.okhttp.version}}}\"", "Automatic-Module-Name: okhttp3.urlconnection", "Bundle-SymbolicName: com.squareup.okhttp3.urlconnection", "-removeheaders: Private-Package" ) dependencies {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Nov 20 16:20:29 GMT 2023 - 764 bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/JvmCallExtensions.kt
import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.suspendCancellableCoroutine import okhttp3.internal.closeQuietly import okio.IOException @ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback {
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
import okhttp3.Call import okhttp3.Callback import okhttp3.Response import okhttp3.internal.closeQuietly import okio.IOException @ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
private val routePlanner = FakeRoutePlanner() private val factory = routePlanner.factory private val taskFaker = routePlanner.taskFaker private val peer = MockHttp2Peer() /** The fake task runner prevents the cleanup runnable from being started. */ private val addressA = factory.newAddress("a") private val routeA1 = factory.newRoute(addressA) private val addressB = factory.newAddress("b")
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/main/kotlin/okhttp3/internal/cache2/Relay.kt
// Write metadata to the end of the file. writeMetadata(upstreamSize) file!!.channel.force(false) // Once everything else is in place we can swap the dirty header for a clean one. writeHeader(PREFIX_CLEAN, upstreamSize, metadata.size.toLong()) file!!.channel.force(false) // This file is complete. synchronized(this@Relay) { complete = true }
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
val request: Request get() = originalRequest val call: RealCall get() = this@RealCall /** * Attempt to enqueue this async call on [executorService]. This will attempt to clean up * if the executor has been shut down by reporting the call as failed. */ fun executeOn(executorService: ExecutorService) { client.dispatcher.assertThreadDoesntHoldLock()
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/connection/RealConnectionPool.kt
* simultaneously adopted and removed. */ private val connections = ConcurrentLinkedQueue<RealConnection>() init { // Put a floor on the keep alive duration, otherwise cleanup will spin loop. require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" } } fun idleConnectionCount(): Int { return connections.count { it.withLock { it.calls.isEmpty() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
} override fun secureConnectEnd( call: Call, handshake: Handshake?, ) { logger.removeHandler(loggerHandler) } override fun callEnd(call: Call) { // Cleanup log handler if failed. logger.removeHandler(loggerHandler) } override fun connectionAcquired( call: Call, connection: Connection, ) { if (random != null) {
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/cache2/RelayTest.kt
assertThat(source.read(sourceBuffer, 1024)).isEqualTo(-1) assertThat(sourceBuffer.size).isEqualTo(0) source.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_CLEAN, 13L, metadata.size, "abcdefghijklm", metadata) } @Test fun multipleSources() { val upstream = Buffer() upstream.writeUtf8("abcdefghijklm") val relay = edit(file, upstream, metadata, 1024)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CertificateChainCleanerTest.kt
.build() val cleaner = get(root.certificate) assertThat(cleaner.clean(list(root), "hostname")).isEqualTo(list(root)) } @Test fun normalizeUnknownSelfSignedCertificate() { val root = HeldCertificate.Builder() .serialNumber(1L) .build() val cleaner = get() assertFailsWith<SSLPeerUnverifiedException> { cleaner.clean(list(root), "hostname") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0)