- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Pairing (0.15 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} } private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* those implied by the returned execution delay. * * Cancellation * ------------ * * Tasks may be canceled while they are waiting to be executed, or while they are executing. * * Canceling a task that is waiting to execute prevents that upcoming execution. Canceling a task * that is currently executing does not impact the ongoing run, but it does prevent a recurrence * from being scheduled. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} throw firstException!! } /** * Returns non-null if we don't need to wait for the launched result. In such cases, this result * must be processed before whatever is waiting in the queue because we may have already acquired * its connection. */ private fun launchTcpConnect(): ConnectResult? { val plan = when { routePlanner.hasNext() -> { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} else { events.add(Failure(t, response)) } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") } fun assertTextMessage(payload: String?) { assertThat(nextEvent()).isEqualTo(Message(string = payload)) } fun assertBinaryMessage(payload: ByteString?) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
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-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
if (cancel) { cancel = false eventSource.cancel() } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") } fun assertExhausted() { assertThat(events).isEmpty() } fun assertEvent( id: String?, type: String?, data: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
// actual response status. code == 100 -> true // Handle Processing (102) & Early Hints (103) and any new codes without failing // 100 and 101 are the exceptions with different meanings // But Early Hints not currently exposed code in (102 until 200) -> true else -> false }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
IPV4(TYPE_A), IPV6(TYPE_AAAA), } @ExperimentalOkHttpApi companion object { const val TYPE_A = 1 const val TYPE_AAAA = 28 /** * Adapt an AsyncDns implementation to Dns, waiting until onComplete is received * and returning results if available. */ fun toDns(vararg asyncDns: AsyncDns): Dns = Dns { hostname -> val allAddresses = mutableListOf<InetAddress>()
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) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
fun connectionCount(): Int = connectionCount.get() fun shutdown() { serverSocket!!.close() executor.shutdown() if (!executor.awaitTermination(5, TimeUnit.SECONDS)) { throw IOException("Gave up waiting for executor to shut down") } } private fun service(from: Socket) { val name = "SocksProxy ${from.remoteSocketAddress}" threadName(name) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0)