- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 344 for feeds2 (0.11 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} fun build(): Http2Connection { return Http2Connection(this) } } /** * Methods in this class must not lock FrameWriter. If a method needs to write a frame, create an * async task to do so. */ inner class ReaderRunnable internal constructor( internal val reader: Http2Reader, ) : Http2Reader.Handler, () -> Unit { override fun invoke() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
CHANGELOG.md
http://squareup.com/robots.txt ``` * Fix: Support executing OkHttp on kotlin-stdlib versions as old as 1.4. The library still builds on up-to-date Kotlin releases (1.6.21) but no longer needs that version as a runtime dependency. This should make it easier to use OkHttp in Gradle plugins. * Fix: Don't start the clock on response timeouts until the request body is fully transmitted.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:31:39 UTC 2024 - 21.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSource.java
// those, this method can cause issues even if the user is dealing with a (finite) slice() // of this source, since the slice's sizeIfKnown() method needs to know the size of the // underlying source to know what its size actually is. return Optional.absent(); } long result = 0L; for (ByteSource source : sources) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 26.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
if err != nil { rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets) wk, err := workers.New(workerSize) if err != nil { return err } for setIdx, set := range pool.sets {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
_2019-10-06_ * Fix: When closing a canceled HTTP/2 stream, don't send the `END_STREAM` flag. This could cause the server to incorrectly interpret the stream as having completed normally. This is most useful when a request body needs to cancel its own call. ## Version 4.2.1 _2019-10-02_ * Fix: In 4.1.0 we introduced a performance regression that prevented connections from being
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
val response = client.newCall(request).execute() assertThat(response.body.string()).isEqualTo("response body") // First CONNECT call needs a new connection. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // Second CONNECT call needs a new connection. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // GET reuses the connection from the second connect.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
cmd/post-policy_test.go
apiRouter := initTestAPIEndPoints(obj, []string{"PostPolicy"}) credentials := globalActiveCred bucketName := minioMetaBucket objectName := "config/x" // This exploit needs browser to be enabled. if !globalBrowserEnabled { globalBrowserEnabled = true defer func() { globalBrowserEnabled = false }() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
public void refresh() {} } /** Returns a policy containing all the permissions we ever need. */ public static Policy permissivePolicy() { return new AdjustablePolicy // Permissions j.u.c. needs directly ( new RuntimePermission("modifyThread"), new RuntimePermission("getClassLoader"), new RuntimePermission("setContextClassLoader"), // Permissions needed to change permissions!
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 37.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
return fi, err } // ListVersions lists current versions, and current deleted // versions returns error for unexpected entries. // showPendingDeletes is set to true if ListVersions needs to list objects marked deleted // but waiting to be replicated func (x xlMetaV2) ListVersions(volume, path string, allParts bool) ([]FileInfo, error) { versions := make([]FileInfo, 0, len(x.versions)) var err error
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 64K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
// 2. Replication config - is omitted from import as remote target credentials are not available from exported data for security reasons. // 3. lifecycle config - if transition rules are present, tier name needs to have been defined. func (a adminAPIHandlers) ImportBucketMetadataHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() // Get current object layer instance.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 33.2K bytes - Viewed (0)