- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Unit (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
if (successCount == 0) { if (e != null) { connectFailed(call.client, route, e) } routeFailureCount++ } } Unit } if (noNewExchangesEvent) { connectionListener.noNewExchanges(this) } } override fun protocol(): Protocol = protocol!! override fun toString(): String {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
private var editCount = 0 override fun poll(): T = delegate.poll() override fun poll( timeout: Long, unit: TimeUnit, ): T? { taskRunner.lock.withLock { val waitUntil = nanoTime + unit.toNanos(timeout) while (true) { val result = poll() if (result != null) return result if (nanoTime >= waitUntil) return null
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-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
import okhttp3.tls.internal.TlsUtil.localhost /** * OkHttp is usually tested with functional tests: these use public APIs to confirm behavior against * MockWebServer. In cases where logic is particularly tricky, we use unit tests. This class makes * it easy to get sample values to use in such tests. * * This class is pretty fast and loose with default values: it attempts to provide values that are
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/internal/http2/Http2Connection.kt
// Visible for testing val readerRunnable = ReaderRunnable(Http2Reader(builder.source, client)) // Guarded by this. private val currentPushRequests = mutableSetOf<Int>() init { if (builder.pingIntervalMillis != 0) { val pingIntervalNanos = TimeUnit.MILLISECONDS.toNanos(builder.pingIntervalMillis.toLong()) writerQueue.schedule("$connectionName ping", pingIntervalNanos) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* [RealConnection.noNewExchanges] property. This defends against races where a connection is * 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 {
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
internal var errorCode: ErrorCode? = null get() = this.withLock { field } /** The exception that explains [errorCode]. Null if no exception was provided. */ internal var errorException: IOException? = null init { if (headers != null) { check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
import okhttp3.FakeRoutePlanner import okhttp3.FakeRoutePlanner.ConnectState.TLS_CONNECTED import okhttp3.internal.concurrent.TaskFaker import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Test /** * Unit test for [FastFallbackExchangeFinder] implementation details. * * This test uses [TaskFaker] to deterministically test racy code. Each function in this test has * the same structure: *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0)