- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for func (0.12 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
private var serverSocket: ServerSocket? = null private var socket: Socket? = null fun setClient(client: Boolean) { if (this.client == client) return this.client = client writer = Http2Writer(bytesOut, client) } fun acceptFrame() { frameCount++ } /** Maximum length of an outbound data frame. */ fun maxOutboundDataLength(): Int = writer.maxDataLength()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp-android/api/okhttp-android.api
public fun <init> (Lokhttp3/AsyncDns$DnsClass;Landroid/net/Network;)V public synthetic fun <init> (Lokhttp3/AsyncDns$DnsClass;Landroid/net/Network;ILkotlin/jvm/internal/DefaultConstructorMarker;)V public fun query (Ljava/lang/String;Lokhttp3/AsyncDns$Callback;)V } public final class okhttp3/android/AndroidAsyncDns$Companion { public final fun getIPv4 ()Lokhttp3/android/AndroidAsyncDns;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 11:07:32 GMT 2024 - 1.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
internal val plansToCancel = CopyOnWriteArrayList<RoutePlanner.Plan>() override fun timeout(): Timeout = timeout @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state. override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
} override fun cancel() { exchange.cancel() } } } override fun route(): Route = route override fun cancel() { // Close the raw socket so we don't end up doing synchronous I/O. rawSocket?.closeQuietly() } override fun socket(): Socket = socket!! /** Returns true if this connection is ready to host new streams. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
* ``` */ BODY, } fun interface Logger { fun log(message: String) companion object { /** A [Logger] defaults output appropriate for the current platform. */ @JvmField val DEFAULT: Logger = DefaultLogger() private class DefaultLogger : Logger { override fun log(message: String) { Platform.get().log(message)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
suspend fun import() { check(fileSystem.metadata(resources).isDirectory) check(fileSystem.metadata(testResources).isDirectory) updateLocalFile() val importResults = readImportResults() writeOutputFile(importResults) } private suspend fun updateLocalFile() = withContext(Dispatchers.IO) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/testing/PlatformRuleTest.kt
val platform = PlatformRule() @Test fun testMode() { println(PlatformRule.getPlatformSystemProperty()) println(Platform.get().javaClass.simpleName) } @Test fun testGreenCase() { } @Test fun testGreenCaseFailingOnLater() { platform.expectFailureFromJdkVersion(PlatformVersion.majorVersion + 1) } @Test fun failureCase() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/JvmCallExtensions.kt
import okio.IOException @ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) {
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
object EventSources { @Deprecated( message = "required for binary-compatibility!", level = DeprecationLevel.HIDDEN, ) @JvmStatic fun createFactory(client: OkHttpClient) = createFactory(client as Call.Factory) @JvmStatic fun createFactory(callFactory: Call.Factory): EventSource.Factory { return EventSource.Factory { request, listener -> val actualRequest =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt
k += BASE } return k + (((BASE - TMIN + 1) * delta) / (delta + SKEW)) } private fun String.requiresEncode( pos: Int, limit: Int, ): Boolean { for (i in pos until limit) { if (this[i].code >= INITIAL_N) return true } return false } private fun String.codePoints( pos: Int, limit: Int, ): List<Int> { val result = mutableListOf<Int>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 03:04:50 GMT 2024 - 8.5K bytes - Viewed (0)