- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 136 for Next (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
private val connectionUser: ConnectionUser, private val fastFallback: Boolean, ) { // State for negotiating the next proxy to use. private var proxies = emptyList<Proxy>() private var nextProxyIndex: Int = 0 // State for negotiating the next socket address to use. private var inetSocketAddresses = emptyList<InetSocketAddress>() // State for negotiating failed routes
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
} } // Call the next interceptor in the chain. val next = copy(index = index + 1, request = request) val interceptor = interceptors[index] @Suppress("USELESS_ELVIS") val response = interceptor.intercept(next) ?: throw NullPointerException( "interceptor $interceptor returned null", )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
* we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. * * Each step may fail. If a retry is possible, a new instance is created with the next plan, which * will be configured differently. */ class ConnectPlan( private val taskRunner: TaskRunner, private val connectionPool: RealConnectionPool, private val readTimeoutMillis: Int,
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/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
* * If this flag is set, the next four * bytes represent the mask key. These bytes appear after any additional bytes specified by [B1_MASK_LENGTH]. */ internal const val B1_FLAG_MASK = 128 /** * Byte 1 mask for the payload length. * * If this value is [PAYLOAD_SHORT], the next two * bytes represent the length. If this value is [PAYLOAD_LONG], the next eight bytes * represent the length. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt
var unionWith: Mapping = mapping index++ while (index < mappings.size) { val next = mappings[index] if (type != canonicalizeType(next.type)) break if (type == TYPE_MAPPED && mappedTo != next.mappedTo) break unionWith = next index++ } result += Mapping( sourceCodePoint0 = mapping.sourceCodePoint0,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt
import java.io.IOException import okhttp3.Interceptor import okhttp3.Response import okhttp3.internal.http.RealInterceptorChain /** * Opens a connection to the target server and proceeds to the next interceptor. The network might * be used for the returned response, or to validate a cached response with a conditional GET. */ object ConnectInterceptor : Interceptor { @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator() while (i.hasNext()) { val recordedResponse = i.next() if (recordedResponse.request.url.equals(url)) { i.remove() return recordedResponse } } val nowMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
fun getContentTypeConnects() { server.enqueue( MockResponse( headers = headersOf("Content-Type", "text/plain"), body = "ABC", ), ) val response = getResponse(newRequest("/")) assertThat(response.body.contentType()).isEqualTo( "text/plain".toMediaType(), ) response.body.close() } @Test fun getContentEncodingConnects() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0)