- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Sait (0.18 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 May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
) val call = client.newCall(Request(server.url("/a"))) val executor = Executors.newSingleThreadExecutor() val result = executor.submit<Response?> { call.execute() } Thread.sleep(100) // wait for it to go in flight. call.cancel() assertFailsWith<IOException> { result.get()!!.body.bytes() } assertThat(server.requestCount).isEqualTo(1) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
override fun coordinatorNotify(taskRunner: TaskRunner) { taskRunner.condition.signal() } /** * Wait a duration in nanoseconds. Unlike [java.lang.Object.wait] this interprets 0 as * "don't wait" instead of "wait forever". */ @Throws(InterruptedException::class) @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN") override fun coordinatorWait(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
).isFalse() val call2 = client.newCall(Request(server.url("/"))) val response2 = call2.execute() assertThat(response2.body.string()).isEqualTo("abc") } /** Wait for the client to receive `dataLength` DATA frames. */ private fun waitForDataFrames(dataLength: Int) { val expectedFrameCount = dataLength / 16384 var dataFrameCount = 0
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do // blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last. // This ensures that we never wait for a blocking operation while holding 'this'. /** True if this peer initiated the connection. */ internal val client: Boolean = builder.client /** User code to run in response to incoming streams or settings. */
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/OkHttpClient.kt
* values must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds. * * The close timeout is the maximum amount of time after the client calls [WebSocket.close] to * wait for a graceful shutdown. If the server doesn't respond the web socket will be canceled. * The default value is 60 seconds. */ fun webSocketCloseTimeout( timeout: Long, unit: TimeUnit,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
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) -
CHANGELOG.md
`LoggingEventListener.androidLogging()` write HTTP calls or events to Logcat. * New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait for a graceful shutdown before it performs an abrupt shutdown. * Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
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/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
creator.setString(0, "AB") creator.setString(1, "C") creator.abort() cache.close() assertJournalEquals("DIRTY k1", "REMOVE k1") } /** On Windows we have to wait until the edit is committed before we can delete its files. */ @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun `unterminated edit is reverted on cache close`(parameters: Pair<FileSystem, Boolean>) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
readBytes.update(acknowledged = unacknowledgedBytesRead) } } else if (!finished && errorExceptionToDeliver == null) { // Nothing to do. Wait until that changes then try again. waitForIo() tryAgain = true } } finally { if (doReadTimeout) { readTimeout.exitAndThrowIfTimedOut()
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)