- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for awaited (0.19 sec)
-
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt
* limitations under the License. */ package okhttp3.tls.internal.der import java.math.BigInteger import java.net.ProtocolException import okio.ByteString /** * ASN.1 adapters adapted from the specifications in [RFC 5280][rfc_5280]. * * [rfc_5280]: https://tools.ietf.org/html/rfc5280 */ @Suppress("UNCHECKED_CAST") // This needs to cast decoded collections. internal object CertificateAdapters { /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
return if (!fieldType.isInstance(value)) null else fieldType.cast(value) } catch (_: NoSuchFieldException) { } c = c.superclass } // Didn't find the field we wanted. As a last gasp attempt, // try to find the value on a delegate. if (fieldName != "delegate") { val delegate = readFieldOrNull(instance, Any::class.java, "delegate")
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/FastFallbackTest.kt
var first = true override fun createSocket(): Socket { if (first) { first = false firstConnectLatch.await() } return super.createSocket() } } client = client.newBuilder() .protocols(listOf(Protocol.H2_PRIOR_KNOWLEDGE))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} val startedTask = startNextTask() val otherTasksStarted = startedTask != yieldCompleteTask try { while (currentTask != self) { taskRunner.condition.await() } } finally { serialTaskQueue.remove(yieldCompleteTask) } // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run.
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/ws/WebSocketHttpTest.kt
object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) { try { latch.await() // The server can't respond to pings! } catch (e: InterruptedException) { throw AssertionError(e) } } }, ) .build(), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
allExceptions.add(e) } latch.countDown() } }, ) } latch.await() // No mutations should be possible after this point if (allAddresses.isEmpty()) { val first = allExceptions.firstOrNull() ?: UnknownHostException("No results for $hostname")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.5K bytes - Viewed (0) -
CHANGELOG.md
introduced in the 5.0.0-alpha.4 release. * Fix: Don't ask `Dns` implementations to resolve strings that are already IP addresses. * Fix: Change fast fallback to race TCP handshakes only. To avoid wasted work, OkHttp will not attempt multiple TLS handshakes for the same call concurrently. * Fix: Don't crash loading the public suffix database in GraalVM native images. The function
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
// We wait at most 1 second, so we don't ever turn multiple lost threads into // a test timeout failure. val waitTime = (entryTime + 1_000_000_000L - System.nanoTime()) if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) { TaskRunner.INSTANCE.lock.withLock { TaskRunner.INSTANCE.cancelAll() } fail<Unit>("Queue still active after 1000 ms") } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} /** For testing: force this web socket to release its threads. */ @Throws(InterruptedException::class) fun tearDown() { taskQueue.shutdown() taskQueue.idleLatch().await(10, TimeUnit.SECONDS) } @Synchronized fun sentPingCount(): Int = sentPingCount @Synchronized fun receivedPingCount(): Int = receivedPingCount
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
call: Call, response: Response, ) { response.close() completionLatch.countDown() } } call.enqueue(callback) completionLatch.await() assertThat(listener.recordedEventTypes()).containsExactly( "CallStart", "ProxySelectStart", "ProxySelectEnd", "DnsStart", "DnsEnd",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0)