- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 222 for exchanges (0.1 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
Connection, ExchangeCodec.Carrier, Lockable { private var http2Connection: Http2Connection? = null // These properties are guarded by `this`. /** * If true, no new exchanges can be created on this connection. It is necessary to set this to * true when removing a connection from the pool; otherwise a racing caller might get it from theCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K 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 Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 12K 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 Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 19.7K bytes - Click Count (0) -
cmd/utils.go
// code, which we now have in `lastReq`. Exchange it for a JWT id_token. q := lastReq.URL.Query() // fmt.Printf("lastReq.URL: %#v q: %#v\n", lastReq.URL, q) code := q.Get("code") oauth2Token, err := oauth2Config.Exchange(ctx, code) if err != nil { return "", fmt.Errorf("unable to exchange code for id token: %v", err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 33K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
} 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( exchange = this, requestDone = true, responseDone = true, socketSinkDone = true,
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 10.5K bytes - Click Count (0) -
.github/workflows/latest-changes.yml
name: Latest Changes on: pull_request_target: branches: - master types: - closed workflow_dispatch: inputs: number: description: PR number required: true debug_enabled: description: 'Run the build with tmate debugging enabled (https://github.com/marketplace/actions/debugging-with-tmate)' required: false default: 'false' jobs: latest-changes:Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Mon Nov 24 14:58:32 GMT 2025 - 1.4K bytes - Click Count (1) -
doc/godebug.md
enabling the HTTP/2 use by the HTTP client broke programs connecting to servers with buggy HTTP/2 implementations. These kinds of changes are unavoidable and [permitted by the Go 1 compatibility rules](/doc/go1compat). Even so, Go provides a mechanism called GODEBUG to reduce the impact such changes have on Go developers using newer toolchains to compile old code. A GODEBUG setting is a `key=value` pair
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Dec 03 00:18:09 GMT 2025 - 24.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) { exchange.flushRequest() responseBuilder = exchange.readResponseHeaders(expectContinue = true) exchange.responseHeadersStart() invokeStartEvent = false } if (responseBuilder == null) { if (requestBody.isDuplex()) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 7.6K bytes - Click Count (0) -
CONTRIBUTING.md
2. Accept the changes.\ If you are sure that the changes are intentional, follow the steps described in the report. This includes adding the description of the changes to the `accepted-public-api-changes.json` file, and providing a reason for each change. You can add the changes to any place in the file, e.g. at the top. 3. Make sure the file with accepted changes is sorted.\
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Nov 25 06:57:22 GMT 2025 - 19K bytes - Click Count (0) -
.github/workflows/update-test-buckets.yml
- name: Check for changes in ci-health repository id: check-changes run: | cd ${GITHUB_WORKSPACE} if [ -n "$(git status --porcelain)" ]; then echo "changes=true" >> $GITHUB_OUTPUT else echo "changes=false" >> $GITHUB_OUTPUT fi - name: Create Pull Request if: steps.check-changes.outputs.changes == 'true'Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Dec 09 22:14:16 GMT 2025 - 2.4K bytes - Click Count (0)