- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for doThing (0.15 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object ShutdownOutputAtEnd : SocketPolicy /** * After accepting the connection and doing TLS (if configured) don't do HTTP/1.1 or HTTP/2 * framing. Ignore the socket completely until the server is shut down. */ object StallSocketAtStart : SocketPolicy /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt
val pins: Set<Pin>, internal val certificateChainCleaner: CertificateChainCleaner? = null, ) { /** * Confirms that at least one of the certificates pinned for `hostname` is in `peerCertificates`. * Does nothing if there are no certificates pinned for `hostname`. OkHttp calls this after a * successful TLS handshake, but before the connection is used. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.2K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
setHeader("Upgrade", "websocket") webSocketListener = listener } /** * Configures this response to be served as a response to an HTTP CONNECT request, either for * doing HTTPS through an HTTP proxy, or HTTP/2 prior knowledge through an HTTP proxy. * * When a new connection is received, all in-tunnel responses are served before the connection is * upgraded to HTTPS or HTTP/2.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
} return null } if (requestMethod != "GET") { // Don't cache non-GET responses. We're technically allowed to cache HEAD requests and some // POST requests, but the complexity of doing so is high and the benefit is low. return null } if (response.hasVaryAll()) { return null } val entry = Entry(response) var editor: DiskLruCache.Editor? = null
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/-UtilJvm.kt
@Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE") internal inline fun Any.wait() = (this as Object).wait() @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE") internal inline fun Any.notify() = (this as Object).notify() @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE") internal inline fun Any.notifyAll() = (this as Object).notifyAll()
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) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val c1 = factory.newConnection(pool, routeA1, 50L) // Running at time 50, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(50L)).isEqualTo(100L) assertThat(pool.connectionCount()).isEqualTo(1) assertThat(c1.socket().isClosed).isFalse() // Running at time 60, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(60L)).isEqualTo(90L)
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-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
BitString::class to BIT_STRING, ByteString::class to OCTET_STRING, Unit::class to NULL, Nothing::class to OBJECT_IDENTIFIER, Nothing::class to UTF8_STRING, String::class to PRINTABLE_STRING, Nothing::class to IA5_STRING, Nothing::class to UTC_TIME, Long::class to GENERALIZED_TIME, AnyValue::class to ANY_VALUE, ) fun any(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* * By completing. */ class TaskFaker : Closeable { @Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadHoldsLock() { if (assertionsEnabled && !taskRunner.lock.isHeldByCurrentThread) { throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this") } } @Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadDoesntHoldLock() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test /** * Integration test to confirm that [TaskRunner] works with a real backend. Business logic is all * exercised by [TaskRunnerTest]. * * This test is doing real sleeping with tolerances of 250 ms. Hopefully that's enough for even the * busiest of CI servers. */ @Tag("Slowish") class TaskRunnerRealBackendTest { private val log = LinkedBlockingDeque<String>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
* this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { lock.assertHeld() while (true) { if (readyQueues.isEmpty()) { return null // Nothing to do. } val now = backend.nanoTime() var minDelayNanos = Long.MAX_VALUE var readyTask: Task? = null var multipleReadyTasks = false
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)