- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for wait (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
* Connections will still be closed if they idle beyond the keep-alive but will be replaced. */ @JvmField val minimumConcurrentCalls: Int = 0, /** How long to wait to retry pre-emptive connection attempts that fail. */ @JvmField val backoffDelayMillis: Long = 60 * 1000, /** How much jitter to introduce in connection retry backoff delays */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
if (sourcePos != upstreamPos) break // No more data upstream. We're done. if (complete) return -1L // Another thread is already reading. Wait for that. if (upstreamReader != null) { timeout.waitUntilNotified(this@Relay) continue } // We will do the read.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
import okhttp3.ExperimentalOkHttpApi /** Handler for mock server requests. */ @ExperimentalOkHttpApi abstract class Dispatcher { /** * Returns a response to satisfy `request`. This method may block (for instance, to wait on * a CountdownLatch). */ @Throws(InterruptedException::class) abstract fun dispatch(request: RecordedRequest): MockResponse /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
/** * Awaits the next HTTP request (waiting up to the specified wait time if necessary), removes it, * and returns it. Callers should use this to verify the request was sent as intended within the * given time. * * @param timeout how long to wait before giving up, in units of [unit] * @param unit a [TimeUnit] determining how to interpret the [timeout] parameter
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
call: Call, inetSocketAddress: InetSocketAddress, proxy: Proxy, ) { try { // Wait for request2 to guarantee we make 2 separate connections to the server. latch1.await() } catch (e: InterruptedException) { throw AssertionError(e) } } override fun connectionAcquired(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
.github/renovate.json
"description": "JDK 11 requirement" }, { "matchPackageNames": ["gradle"], "allowedVersions": "<8.0", "description": "Recent release, not compatible with pinned AGP and Kotlin versions yet. Wait for AGP 8?" }, { "matchPackageNames": ["com.android.tools.build:gradle"], "allowedVersions": "<7.4", "description": "Recent release, no compatible Intellij stable release (2023.1)" } ]
Json - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Feb 18 14:22:17 GMT 2023 - 1.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
override fun responseHeadersEnd( call: Call, response: Response, ) { try { // Wait for the server to send the duplex response before acting on the 301 response // and resetting the stream. duplexResponseSent.await() } catch (e: InterruptedException) { throw AssertionError() }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
connectResult = launchTcpConnect() nextTcpConnectAtNanos = now + connectDelayNanos awaitTimeoutNanos = connectDelayNanos } // Wait for an in-flight connect to complete or fail. if (connectResult == null) { connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
i.remove() return recordedResponse } } val nowMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) if (nowMillis >= timeoutMillis) break (this as Object).wait(timeoutMillis - nowMillis) } throw AssertionError("Timed out waiting for response to $url") } companion object { val TIMEOUT_MILLIS = TimeUnit.SECONDS.toMillis(10) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0)