- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for loop (0.22 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
assertThat(e).isInstanceOf(ConnectionEvent.ConnectStart::class.java) } else { eventSequence.forEach loop@{ when (e.closes(it)) { null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } } Assertions.fail<Any>("event $e without matching start event") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt
var maxStaleSeconds = -1 var minFreshSeconds = -1 var onlyIfCached = false var noTransform = false var immutable = false var canUseHeaderValue = true var headerValue: String? = null loop@ for (i in 0 until headers.size) { val name = headers.name(i) val value = headers.value(i) when { name.equals("Cache-Control", ignoreCase = true) -> { if (headerValue != null) {
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-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
assertThat(e).matchesPredicate { it is CallStart || it is Canceled } } else { eventSequence.forEach loop@{ when (e.closes(it)) { null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } } fail<Any>("event $e without matching start event") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9K bytes - Viewed (1) -
gradlew
# Roll the args list around exactly as many times as the number of # args, so each arg winds up back in the position where it started, but # possibly modified. # # NB: a `for` loop captures its iteration list before it begins, so # changing the positional parameters here affects neither the number of # iterations, nor the values presented in `arg`.
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingConnectionWindowChanged(windowCounter: WindowCounter) /** Noop implementation */ object None : FlowControlListener { override fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* `permessage-deflate` and four parameters, `client_max_window_bits`, `client_no_context_takeover`, * `server_max_window_bits`, and `server_no_context_takeover`. * * Typically this will look like one of the following: * * ``` * Sec-WebSocket-Extensions: permessage-deflate * Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits="15"
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/MultipartReader.kt
/** * Reads a stream of [RFC 2046][rfc_2046] multipart body parts. Callers read parts one-at-a-time * until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. * * Typical use loops over the parts in sequence: * * ```kotlin * val response: Response = call.execute() * val multipartReader = MultipartReader(response.body!!) * * multipartReader.use { * while (true) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K bytes - Viewed (0) -
build.gradle.kts
testRuntimeOnly(rootProject.libs.junit.vintage.engine) } tasks.withType<Test> { useJUnitPlatform() jvmArgs( "-Dokhttp.platform=$platform", ) if (platform == "loom") { jvmArgs( "-Djdk.tracePinnedThreads=short", ) } val javaToolchains = project.extensions.getByType<JavaToolchainService>() javaLauncher.set(javaToolchains.launcherFor {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:32:42 GMT 2024 - 8.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
assertThat(inflater.inflate(message)).isEqualTo("Hello inflation!".encodeUtf8()) } /** * We had a bug where self-finishing inflater streams would infinite loop! * https://github.com/square/okhttp/issues/8078 */ @Test fun `inflate returns finished before bytesRead reaches input length`() { val inflater = MessageInflater(false) val message = "53621260020000".decodeHex()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 06 05:31:00 GMT 2024 - 5K bytes - Viewed (0)