- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for undelegate (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
import okio.Buffer import okio.ForwardingSink import okio.Sink /** A sink that never throws IOExceptions, even if the underlying sink does. */ internal open class FaultHidingSink( delegate: Sink, val onException: (IOException) -> Unit, ) : ForwardingSink(delegate) { private var hasErrors = false override fun write( source: Buffer, byteCount: Long, ) { if (hasErrors) { source.skip(byteCount)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt
val uppercaseBody: ResponseBody = object : ForwardingResponseBody(response.body) { override fun source(): BufferedSource { return uppercaseSource(delegate().source()).buffer() } } return response.newBuilder() .body(uppercaseBody) .build() } private fun uppercaseSource(source: BufferedSource): ForwardingSource {
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) -
android-test/src/androidTest/java/okhttp/android/test/sni/SniOverrideTest.kt
OkHttpClient.Builder() .build() @Test fun getWithCustomSocketFactory() { assumeTrue(Build.VERSION.SDK_INT >= 24) class CustomSSLSocketFactory( delegate: SSLSocketFactory, ) : DelegatingSSLSocketFactory(delegate) { override fun configureSocket(sslSocket: SSLSocket): SSLSocket { if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) { val parameters = sslSocket.sslParameters
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
val call = RealCall(client, Request(address.url), forWebSocket = false) val chain = newChain(call) return RealRoutePlanner( taskRunner = client.taskRunner, connectionPool = client.connectionPool.delegate, readTimeoutMillis = client.readTimeoutMillis, writeTimeoutMillis = client.writeTimeoutMillis, socketConnectTimeoutMillis = chain.connectTimeoutMillis,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
private val delegate: MutableIterator<DiskLruCache.Snapshot> = cache.snapshots() private var nextUrl: String? = null private var canRemove = false override fun hasNext(): Boolean { if (nextUrl != null) return true canRemove = false // Prevent delegate.remove() on the wrong item! while (delegate.hasNext()) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
return UnknownLengthSource() } /** * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled * connections. */ private fun detachTimeout(timeout: ForwardingTimeout) { val oldDelegate = timeout.delegate timeout.setDelegate(Timeout.NONE) oldDelegate.clearDeadline()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
return existingTask.latch } for (futureTask in futureTasks) { if (futureTask is AwaitIdleTask) { return futureTask.latch } } // Don't delegate to schedule() because that enforces shutdown rules. val newTask = AwaitIdleTask() if (scheduleAndDecide(newTask, 0L, recurrence = false)) { taskRunner.kickCoordinator(this) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
return super.configureSocket(sslSocket) } } } private class RecordingSSLSocketFactory( delegate: SSLSocketFactory, ) : DelegatingSSLSocketFactory(delegate) { val socketsCreated = mutableListOf<SSLSocket>() override fun configureSocket(sslSocket: SSLSocket): SSLSocket { socketsCreated.add(sslSocket)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/CustomCipherSuites.java
/** * An SSL socket factory that forwards all calls to a delegate. Override {@link #configureSocket} * to customize a created socket before it is returned. */ static class DelegatingSSLSocketFactory extends SSLSocketFactory { protected final SSLSocketFactory delegate; DelegatingSSLSocketFactory(SSLSocketFactory delegate) { this.delegate = delegate; }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Mar 14 21:57:42 GMT 2019 - 6.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
} fun enqueueResponse(response: MockResponse) { delegate.enqueueResponse(response.wrap()) } override fun shutdown() { delegate.shutdown() } fun setFailFast(failFast: Boolean) { delegate.setFailFast(failFast) } fun setFailFast(failFastResponse: MockResponse?) { delegate.setFailFast(failFastResponse?.wrap()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Oct 18 12:55:43 GMT 2020 - 1.3K bytes - Viewed (0)