Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 775 for readTo (1.12 sec)

  1. internal/event/config_test.go

    	targetList2 := NewTargetList(t.Context())
    	if err := targetList2.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	testCases := []struct {
    		reader     *strings.Reader
    		region     string
    		targetList *TargetList
    		expectErr  bool
    	}{
    		{reader1, "eu-west-1", nil, true},
    		{reader2, "us-east-1", targetList1, true},
    		{reader4, "us-east-1", targetList1, true},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  2. build-logic-commons/module-identity/src/main/kotlin/gradlebuild/identity/extension/ReleasedVersionsDetails.kt

        val lowestInterestingVersion: GradleVersion = GradleVersion.version("0.8")
        val lowestTestedVersion: GradleVersion = GradleVersion.version("4.0")
    
        init {
            val releasedVersions = releasedVersionsFile.asFile.reader().use {
                Gson().fromJson(it, ReleasedVersions::class.java)
            }
    
            val latestFinalRelease = releasedVersions.finalReleases.first()
            val latestRelease =
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Sep 10 06:04:09 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    		apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err)
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    
    	const mapEntryOverhead = 200
    
    	var (
    		reader        io.Reader
    		actualSize    int64 = -1
    		fileName      string
    		fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100)
    	)
    
    	maxParts := 1000
    	// Canonicalize the form values into http.Header.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/tier-last-day-stats_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *DailyAllTierStats) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0004 uint32
    	zb0004, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if (*z) == nil {
    		(*z) = make(DailyAllTierStats, zb0004)
    	} else if len((*z)) > 0 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 117.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 115.9K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package bandwidth
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  8. impl/maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java

            // [01] clean:clean
            // [02] modello:xpp3-writer
            // [03] modello:java
            // [04] modello:xpp3-reader
            // [05] modello:xpp3-writer
            // [06] modello:java
            // [07] modello:xpp3-reader
            // [08] plugin:descriptor
            // [09] resources:resources
            // [10] compiler:compile
            // [11] resources:testResources
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 10:01:14 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  9. samples/guide/src/main/java/okhttp3/recipes/kt/PostFile.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.RequestBody.Companion.asRequestBody
    
    class PostFile {
      private val client = OkHttpClient()
    
      fun run() {
        val file = File("README.md")
    
        val request =
          Request(
            url = "https://api.github.com/markdown/raw".toHttpUrl(),
            body = file.asRequestBody(MEDIA_TYPE_MARKDOWN),
          )
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  10. src/bufio/example_test.go

    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    	writer := bufio.NewWriter(&buf)
    
    	data := "Hello, world!\nThis is a ReadFrom example."
    	reader := strings.NewReader(data)
    
    	n, err := writer.ReadFrom(reader)
    	if err != nil {
    		fmt.Println("ReadFrom Error:", err)
    		return
    	}
    
    	if err = writer.Flush(); err != nil {
    		fmt.Println("Flush Error:", err)
    		return
    	}
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top