- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Action (0.17 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
stream.requestBody.use { stream.responseBody.use { while (true) { val action = actions.poll() ?: break action(stream) } } } return@FutureTask null } } /** Returns once all stream actions complete successfully. */ fun awaitSuccess() { val futureTask = results.poll(5, TimeUnit.SECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
return lock.withLock(action) } inline fun <T> Http2Connection.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) } inline fun <T> Http2Stream.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) } inline fun <T> Http2Writer.withLock(action: () -> T): T {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 2.1K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
type: String?, data: String, ) fun onRetryChange(timeMs: Long) } /** * Process the next event. This will result in a single call to [Callback.onEvent] *unless* the * data section was empty. Any number of calls to [Callback.onRetryChange] may occur while * processing an event. * * @return false when EOF is reached */ @Throws(IOException::class) fun processNextEvent(): Boolean {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/PunycodeTest.kt
*/ package okhttp3.internal.idn import kotlin.test.Test import kotlin.test.assertEquals import kotlin.test.assertNull class PunycodeTest { /** https://datatracker.ietf.org/doc/html/rfc3492#section-7.1 */ @Test fun rfc3492Samples() { // (A) Arabic (Egyptian) testEncodeDecode( unicode = "ليهمابتكلموشعربي؟", punycode = "xn--egbpdaj6bu4bxfgehfvwxn", ) // (B) Chinese (simplified)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
} return SimpleIdnaMappingTable(result) } internal data class Mapping( val sourceCodePoint0: Int, val sourceCodePoint1: Int, val type: Int, val mappedTo: ByteString, ) { val section: Int get() = sourceCodePoint0 and 0x1fff80 val rangeStart: Int get() = sourceCodePoint0 and 0x7f val hasSingleSourceCodePoint: Boolean get() = sourceCodePoint0 == sourceCodePoint1
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.8K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
.setPathDegradationMigration(ConnectionMigrationOptions.MIGRATION_OPTION_ENABLED) .setAllowNonDefaultNetworkUsage(ConnectionMigrationOptions.MIGRATION_OPTION_ENABLED) .build(), ) .setDnsOptions( DnsOptions.Builder() .setUseHttpStackDnsResolver(DnsOptions.DNS_OPTION_ENABLED)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 24 13:19:43 GMT 2024 - 6.2K bytes - Viewed (0) -
okcurl/build.gradle.kts
} } tasks.shadowJar { mergeServiceFiles() } graal { mainClass("okhttp3.curl.MainCommandLineKt") outputName("okcurl") graalVersion(libs.versions.graalvm.get()) javaVersion("11") option("--no-fallback") if (Os.isFamily(Os.FAMILY_WINDOWS)) { // May be possible without, but autodetection is problematic on Windows 10 // see https://github.com/palantir/gradle-graal
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/CookieJar.kt
* database to hold accepted cookies. The [cookie storage model][rfc_6265_53] specifies policies for * updating and expiring cookies. * * [rfc_6265_53]: https://tools.ietf.org/html/rfc6265#section-5.3 */ interface CookieJar { /** * Saves [cookies] from an HTTP response to this store according to this jar's policy. *
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) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
*/ object KeepOpen : SocketPolicy /** * Close the socket after the response. This is the default HTTP/1.0 behavior. For HTTP/2 * connections, this sends a [GOAWAYframe](https://tools.ietf.org/html/rfc7540#section-6.8) * immediately after the response and will close the connection when the client's socket * is exhausted. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0)