Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for NewWriter (0.09 sec)

  1. src/archive/zip/writer_test.go

    	// write a zip file
    	archive := new(bytes.Buffer)
    	w := NewWriter(archive)
    
    	for i := range files {
    		f := &files[i]
    		f.crc32 = crc32.ChecksumIEEE(f.content)
    		size := uint64(len(f.content))
    		f.uncompressedSize = size
    		f.compressedSize = size
    
    		var compressedContent []byte
    		if f.method == Deflate {
    			var buf bytes.Buffer
    			w, err := flate.NewWriter(&buf, flate.BestSpeed)
    			if err != nil {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jan 28 04:20:09 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  2. src/archive/tar/writer_test.go

    		}
    	})
    
    	t.Run("NegativeSize", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		hdr := &Header{Name: "small.txt", Size: -1}
    		if err := tw.WriteHeader(hdr); err == nil {
    			t.Fatalf("WriteHeader() = nil, want non-nil error")
    		}
    	})
    
    	t.Run("BeforeHeader", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		if _, err := tw.Write([]byte("Kilts")); err != ErrWriteTooLong {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Feb 03 16:38:43 UTC 2025
    - 39.8K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeallTierStats(b *testing.B) {
    	v := allTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeallTierStats(b *testing.B) {
    	v := allTierStats{}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. src/bufio/example_test.go

    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"os"
    	"strconv"
    	"strings"
    )
    
    func ExampleWriter() {
    	w := bufio.NewWriter(os.Stdout)
    	fmt.Fprint(w, "Hello, ")
    	fmt.Fprint(w, "world!")
    	w.Flush() // Don't forget to flush!
    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    		b := w.AvailableBuffer()
    		b = strconv.AppendInt(b, i, 10)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    	if blockSize < 8<<10 {
    		blockSize = 128 << 10
    	}
    	w := metacacheWriter{
    		mw:        nil,
    		blockSize: blockSize,
    	}
    	w.creator = func() error {
    		s2w := s2.NewWriter(out, s2.WriterBlockSize(blockSize), s2.WriterConcurrency(2))
    		w.mw = msgp.NewWriter(s2w)
    		w.creator = nil
    		if err := w.mw.WriteByte(metacacheStreamVersion); err != nil {
    			return err
    		}
    
    		w.closer = func() (err error) {
    			defer func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/FilesTest.java

      }
    
      public void testNewWriter() throws IOException {
        File temp = createTempFile();
        assertThrows(NullPointerException.class, () -> Files.newWriter(temp, null));
    
        assertThrows(NullPointerException.class, () -> Files.newWriter(null, UTF_8));
    
        BufferedWriter w = Files.newWriter(temp, UTF_8);
        try {
          w.write(I18N);
        } finally {
          w.close();
        }
    
        File i18nFile = getTestFile("i18n.txt");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/FilesTest.java

      }
    
      public void testNewWriter() throws IOException {
        File temp = createTempFile();
        assertThrows(NullPointerException.class, () -> Files.newWriter(temp, null));
    
        assertThrows(NullPointerException.class, () -> Files.newWriter(null, UTF_8));
    
        BufferedWriter w = Files.newWriter(temp, UTF_8);
        try {
          w.write(I18N);
        } finally {
          w.close();
        }
    
        File i18nFile = getTestFile("i18n.txt");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  8. src/bufio/bufio_test.go

    	dstBuf := new(bytes.Buffer)
    	dst := NewWriter(dstBuf)
    	for i := 0; i < b.N; i++ {
    		srcBuf.Reset()
    		dstBuf.Reset()
    		dst.Reset(dstBuf)
    		io.Copy(dst, src)
    	}
    }
    
    func BenchmarkWriterCopyUnoptimal(b *testing.B) {
    	srcBuf := bytes.NewBuffer(make([]byte, 8192))
    	src := onlyReader{srcBuf}
    	dstBuf := new(bytes.Buffer)
    	dst := NewWriter(onlyWriter{dstBuf})
    	for i := 0; i < b.N; i++ {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  9. cmd/callhome.go

    	return err
    }
    
    func createHealthJSONGzip(ctx context.Context, healthInfo madmin.HealthInfo) []byte {
    	var b bytes.Buffer
    	gzWriter := gzip.NewWriter(&b)
    
    	header := struct {
    		Version string `json:"version"`
    	}{Version: healthInfo.Version}
    
    	enc := json.NewEncoder(gzWriter)
    	if e := enc.Encode(header); e != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  10. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    		format := newFormatErasureV3(setCount, setDriveCount)
    		format.ID = deploymentID
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
Back to top