- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 300 for NewMreader (0.47 sec)
-
cmd/untar.go
bf := bufio.NewReader(r) switch f := detect(bf); f { case formatGzip: gz, err := gzip.NewReader(bf) if err != nil { return err } defer gz.Close() r = gz case formatS2: r = s2.NewReader(bf) case formatZstd: // Limit to 16 MiB per stream. dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20)) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 6K bytes - Viewed (0) -
src/mime/multipart/formdata_test.go
package multipart import ( "bytes" "fmt" "io" "math" "net/textproto" "os" "strings" "testing" ) func TestReadForm(t *testing.T) { b := strings.NewReader(strings.ReplaceAll(message, "\n", "\r\n")) r := NewReader(b, boundary) f, err := r.ReadForm(25) if err != nil { t.Fatal("ReadForm:", err) } defer f.RemoveAll() if g, e := f.Value["texta"][0], textaValue; g != e {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14K bytes - Viewed (0) -
src/compress/lzw/reader_test.go
runtime.GC() b.StartTimer() for i := 0; i < b.N; i++ { io.Copy(io.Discard, NewReader(bytes.NewReader(buf1), LSB, 8)) } }) b.Run(fmt.Sprint("1e-Reuse", e), func(b *testing.B) { b.StopTimer() b.SetBytes(int64(n)) buf1 := getInputBuf(buf, n) runtime.GC() b.StartTimer() r := NewReader(bytes.NewReader(buf1), LSB, 8) for i := 0; i < b.N; i++ { io.Copy(io.Discard, r) r.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:58 UTC 2024 - 7.6K bytes - Viewed (0) -
src/internal/zstd/fuzz_test.go
f.Fuzz(func(t *testing.T, b []byte) { cmd := exec.Command(zstd, "-z") cmd.Stdin = bytes.NewReader(b) var compressed bytes.Buffer cmd.Stdout = &compressed cmd.Stderr = os.Stderr if err := cmd.Run(); err != nil { t.Errorf("running zstd failed: %v", err) } r := NewReader(bytes.NewReader(compressed.Bytes())) got, err := io.ReadAll(r) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 04:10:45 UTC 2024 - 4.5K bytes - Viewed (0) -
src/internal/trace/reader_test.go
// getters can be made to panic. Turn this on once the parser is meant to // reject invalid traces. const testGetters = false f.Fuzz(func(t *testing.T, b []byte) { r, err := trace.NewReader(bytes.NewReader(b)) if err != nil { return } for { ev, err := r.ReadEvent() if err != nil { break } if !testGetters { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 3.7K bytes - Viewed (0) -
src/compress/gzip/gzip_test.go
func TestEmpty(t *testing.T) { buf := new(bytes.Buffer) if err := NewWriter(buf).Close(); err != nil { t.Fatalf("Writer.Close: %v", err) } r, err := NewReader(buf) if err != nil { t.Fatalf("NewReader: %v", err) } if want := (Header{OS: 255}); !reflect.DeepEqual(r.Header, want) { t.Errorf("Header mismatch:\ngot %#v\nwant %#v", r.Header, want) } b, err := io.ReadAll(r) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 17:10:06 UTC 2024 - 6K bytes - Viewed (0) -
src/encoding/xml/xml_test.go
input := `<FOO></FOO> ` d := NewDecoder(strings.NewReader(input)) var err error for _, err = d.RawToken(); err == nil; _, err = d.RawToken() { } if err != io.EOF { t.Fatalf("d.RawToken() = _, %v, want _, io.EOF", err) } } func TestTrailingToken(t *testing.T) { input := `<FOO></FOO> ` d := NewDecoder(strings.NewReader(input)) var err error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 36.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/metrics/metrics_test.go
expectedValue := prefix + ` apiserver_authorization_decisions_total{decision="allowed",name="myname",type="mytype"} 1 ` if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(expectedValue), metrics...); err != nil { t.Fatal(err) } authorizationDecisionsTotal.Reset() } // deny { dummyAuthorizer.decision = authorizer.DecisionDeny
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 13:20:59 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/storage-datatypes_gen_test.go
} vn := BaseOptions{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeBaseOptions(b *testing.B) { v := BaseOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 62.6K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
} vn := localLockMap{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodelocalLockMap(b *testing.B) { v := localLockMap{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6.7K bytes - Viewed (0)