- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 610 for exchange (0.1 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
fun noNewExchangesOnConnection() { codec.carrier.noNewExchanges() } fun cancel() { codec.cancel() } /** * Revoke this exchange's access to streams. This is necessary when a follow-up request is * required but the preceding exchange hasn't completed yet. */ fun detachWithViolence() { codec.cancel() call.messageDone(this, requestDone = true, responseDone = true, e = null) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
private void put(TransferEvent event, boolean last) { try { Exchange exchange; if (blockOnLastEvent && last) { exchange = new BlockingExchange(event); } else { exchange = new Exchange(event); } eventQueue.put(exchange); exchange.waitForProcessed(); } catch (InterruptedException e) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
private val index: Int, internal val exchange: Exchange?, internal val request: Request, internal val connectTimeoutMillis: Int, internal val readTimeoutMillis: Int, internal val writeTimeoutMillis: Int, ) : Interceptor.Chain { private var calls: Int = 0 internal fun copy( index: Int = this.index, exchange: Exchange? = this.exchange, request: Request = this.request,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jul 06 09:38:30 UTC 2024 - 15.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
if (shouldIgnoreAndWaitForRealResponse(code, exchange)) { responseBuilder = exchange.readResponseHeaders(expectContinue = false)!! if (invokeStartEvent) { exchange.responseHeadersStart() } response = responseBuilder .request(request) .handshake(exchange.connection.handshake()) .sentRequestAtMillis(sentRequestMillis)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
exchange: Exchange, requestDone: Boolean, responseDone: Boolean, e: E, ): E { if (exchange != this.exchange) return e // This exchange was detached violently! var bothStreamsDone = false var callDone = false this.withLock { if (requestDone && requestBodyOpen || responseDone && responseBodyOpen) { if (requestDone) requestBodyOpen = false
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
.request(request) .priorResponse(priorResponse?.stripBody()) .build() val exchange = call.interceptorScopedExchange val followUp = followUpRequest(response, exchange) if (followUp == null) { if (exchange != null && exchange.isDuplex) { call.timeoutEarlyExit() } closeActiveExchange = false return response
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt
@Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response { val realChain = chain as RealInterceptorChain val exchange = realChain.call.initExchange(realChain) val connectedChain = realChain.copy(exchange = exchange) return connectedChain.proceed(realChain.request) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
response: Response, ) { val exchange = response.exchange val streams: Streams try { checkUpgradeSuccess(response, exchange) streams = exchange!!.newWebSocketStreams() } catch (e: IOException) { failWebSocket(e, response) response.closeQuietly() exchange?.webSocketUpgradeFailed() return }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0)