- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 309 for Exchange (0.05 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
*/ class RealInterceptorChain( internal val call: RealCall, private val interceptors: List<Interceptor>, private val index: Int, internal val exchange: Exchange?, internal val request: Request, internal val connectTimeoutMillis: Int, internal val readTimeoutMillis: Int, internal val writeTimeoutMillis: Int, override val authenticator: Authenticator, override val cache: Cache?,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 12.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
exchange: Exchange, requestDone: Boolean = false, responseDone: Boolean = false, socketSourceDone: Boolean = false, socketSinkDone: Boolean = false, e: IOException?, ): IOException? { if (exchange != this.exchange) return e // This exchange was detached violently! var allStreamsDone = false var callDone = false withLock { if ( requestDone && requestBodyOpen ||Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
.request(request) .priorResponse(priorResponse?.stripBody()) .build() val exchange = call.interceptorScopedExchange val followUp = followUpRequest(response, exchange, chain) if (followUp == null) { if (exchange != null && exchange.isDuplex) { call.timeoutEarlyExit() } closeActiveExchange = false
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
return connect } /** * Returns the connection already attached to the call if it's eligible for a new exchange. * * If the call's connection exists and is eligible for another exchange, it is returned. If it * exists but cannot be used for another exchange, it is closed and this returns null. */ private fun planReuseCallConnection(): ReusePlan? {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
socketAddress = socketAddress, ) fun newChain(call: RealCall): RealInterceptorChain = RealInterceptorChain( call = call, interceptors = listOf(), index = 0, exchange = null, request = call.request(), ) fun newRoutePlanner( client: OkHttpClient, address: Address = newAddress(), ): RealRoutePlanner {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 6.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt
* provides support. */ QUIC("quic"), /** * HTTP/3 is the third and upcoming major version of the Hypertext Transfer Protocol used to * exchange information. HTTP/3 runs over QUIC, which is published as RFC 9000. * * HTTP/3 is not natively supported by OkHttp, but provided to allow a theoretical interceptor * that provides support. */ HTTP_3("h3"),
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 4.6K bytes - Click Count (0) -
doc/godebug.md
It is also possible to set the default `GODEBUG` for a given program (discussed below). When preparing any change that is permitted by Go 1 compatibility but may nonetheless break some existing programs, we first engineer the change to keep as many existing programs working as possible. For the remaining programs, we define a new GODEBUG setting that
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Mar 20 15:49:10 GMT 2026 - 26K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val socket = MockWebServerSocket(raw) while (true) { val socketStillGood = processOneRequest(socket) // Clean up after the last exchange on a socket. if (!socketStillGood) { raw.close() openClientSockets.remove(raw) return false }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 40.3K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/common/admin/sidebar.jsp
<a href="${fe:url('/admin/relatedquery/')}" class="nav-link <c:if test="${param.menuType=='relatedQuery'}">active</c:if>" <c:if test="${param.menuType=='relatedQuery'}">aria-current="page"</c:if>> <i class='fa fa-exchange-alt nav-icon' aria-hidden="true"></i> <p><la:message key="labels.menu_related_query" /></p> </a></li></c:if> <c:if test="${fe:permission('admin-pathmap-view')}"> <li class="nav-item">Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 21K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/internal.kt
} } return charset to finalContentType } internal fun MediaType?.charsetOrUtf8(): Charset = this?.charset() ?: Charsets.UTF_8 internal val Response.connection: RealConnection get() = this.exchange!!.connection internal fun OkHttpClient.Builder.taskRunnerInternal(taskRunner: TaskRunner) = this.taskRunner(taskRunner) internal fun buildConnectionPool( connectionListener: ConnectionListener,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 3.8K bytes - Click Count (0)