- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 112 for whale (0.23 sec)
-
okhttp/src/test/java/okhttp3/RecordingCallback.kt
*/ @Synchronized fun await(url: HttpUrl): RecordedResponse { val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator() while (i.hasNext()) { val recordedResponse = i.next() if (recordedResponse.request.url.equals(url)) { i.remove() return recordedResponse } }
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/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
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/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
continue // Not a header we're interested in. } val header = responseHeaders.value(i) // Parse each extension. var pos = 0 while (pos < header.length) { val extensionEnd = header.delimiterOffset(',', pos) val extensionTokenEnd = header.delimiterOffset(';', pos, extensionEnd)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/HeadersReader.kt
headerLimit -= line.length.toLong() return line } /** Reads headers or trailers. */ fun readHeaders(): Headers { val result = Headers.Builder() while (true) { val line = readLine() if (line.isEmpty()) break result.addLenient(line) } return result.build() } companion object { private const val HEADER_LIMIT = 256 * 1024
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.4K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
} println() } // Stream the response to the System.out as it is returned from the server. val out = System.out.sink() val source = response.body.source() while (!source.exhausted()) { out.write(source.buffer, source.buffer.size) out.flush() } response.body.close() } catch (e: IOException) { e.printStackTrace() } finally { close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
mockwebserver-junit5/src/main/kotlin/mockwebserver3/junit5/internal/MockWebServerExtension.kt
import org.junit.jupiter.api.extension.ParameterContext import org.junit.jupiter.api.extension.ParameterResolver /** * Runs MockWebServer for the duration of a single test method. * * Specifically while junit instances passes into test constructor * are typically shares amongst all tests, a fresh instance will be * received here. Use with @BeforeAll and @AfterAll, is not supported. * * There are 3 ids for instances
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 11 12:12:36 GMT 2024 - 4.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* .build(); * ``` * * ## Force a Cache Response * * Sometimes you'll want to show resources if they are available immediately, but not otherwise. * This can be used so your application can show *something* while waiting for the latest data to be * downloaded. To restrict a request to locally-cached resources, add the `only-if-cached` * directive: * * ```java * Request request = new Request.Builder()
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/connection/FastFallbackExchangeFinder.kt
*/ private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>()) override fun find(): RealConnection { var firstException: IOException? = null try { while (tcpConnectsInFlight.isNotEmpty() || routePlanner.hasNext()) { if (routePlanner.isCanceled()) throw IOException("Canceled") // Launch a new connection if we're ready to.
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/main/kotlin/okhttp3/internal/-CacheControlCommon.kt
// Might specify additional cache-control params. We invalidate just in case. canUseHeaderValue = false } else -> { continue@loop } } var pos = 0 while (pos < value.length) { val tokenStart = pos pos = value.indexOfElement("=,;", pos) val directive = value.substring(tokenStart, pos).trim() val parameter: String?
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
/** Returns a callable that reads all of source, closes it, and returns the bytes. */ private fun sourceReader(source: Source?): Callable<ByteString> { return Callable { val buffer = Buffer() while (source!!.read(buffer, 16384) != -1L) { } source.close() buffer.readByteString() } } private fun assertFile( prefix: ByteString, upstreamSize: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0)