- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for foreach (0.25 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
} private fun checkForStartEvent(e: ConnectionEvent) { if (eventSequence.isEmpty()) { 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 } }
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) -
native-image-tests/src/main/kotlin/okhttp3/TestRegistration.kt
) { access.registerAsUsed(java) RuntimeReflection.register(java) java.constructors.forEach { RuntimeReflection.register(it) } java.declaredMethods.forEach { RuntimeReflection.register(it) } java.declaredFields.forEach { RuntimeReflection.register(it) } java.methods.forEach { RuntimeReflection.register(it) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
Dns { hostname -> val allAddresses = mutableListOf<InetAddress>() val allExceptions = mutableListOf<IOException>() val latch = CountDownLatch(asyncDns.size) asyncDns.forEach { it.query( hostname, object : Callback { override fun onResponse( hostname: String, addresses: List<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-testing-support/src/main/kotlin/okhttp3/testing/PlatformRule.kt
} } fun rethrowIfNotExpected(e: Throwable) { versionChecks.forEach { (versionMatcher, failureMatcher) -> if (versionMatcher.matches(PlatformVersion) && failureMatcher.matches(e)) { return } } throw e } fun failIfExpected() { versionChecks.forEach { (versionMatcher, failureMatcher) -> if (versionMatcher.matches(PlatformVersion)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
} private fun checkForStartEvent(e: CallEvent) { if (eventSequence.isEmpty()) { 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 } }
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
this.withLock { if (streams.isNotEmpty()) { streamsToClose = streams.values.toTypedArray() streams.clear() } } streamsToClose?.forEach { stream -> ignoreIoExceptions { stream.close(streamCode, cause) } } // Close the writer to release its resources (such as deflaters). ignoreIoExceptions {
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/internal/connection/ConnectPlan.kt
import okio.source /** * A single attempt to connect to a remote server, including these steps: * * * [TCP handshake][connectSocket] * * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server * we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
import org.opentest4j.TestAbortedException /** * This test binds two different web servers (IPv4 and IPv6) to the same port, but on different * local IP addresses. Requests made to `127.0.0.1` will reach the IPv4 server, and requests made to * `::1` will reach the IPv6 server. * * By orchestrating two different servers with the same port but different IP addresses, we can * test what OkHttp does when both are reachable, or if only one is reachable. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
val body = response.body.string() assertThat(body).contains("Peter the person") } } results.forEach { it.get() } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 11:15:46 GMT 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
* q: cute #puppies * f: images * ``` * * In addition to composing URLs from their component parts and decomposing URLs into their * component parts, this class implements relative URL resolution: what address you'd reach by * clicking a relative link on a specified page. For example: * * ```java * HttpUrl base = HttpUrl.parse("https://www.youtube.com/user/WatchTheDaily/videos"); * HttpUrl link = base.resolve("../../watch?v=cbP2N1BQdYc");
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1)