- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for newScanner (0.16 sec)
-
src/bufio/example_test.go
func ExampleScanner_lines() { scanner := bufio.NewScanner(os.Stdin) for scanner.Scan() { fmt.Println(scanner.Text()) // Println will add back the final '\n' } if err := scanner.Err(); err != nil { fmt.Fprintln(os.Stderr, "reading standard input:", err) } } // Return the most recent call to Scan as a []byte. func ExampleScanner_Bytes() { scanner := bufio.NewScanner(strings.NewReader("gopher")) for scanner.Scan() {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Nov 01 21:52:12 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/s3select/jstream/scanner_test.go
largeInput = make([]byte, 1024*1024*128) // 128MB ) func TestScanner(t *testing.T) { data := []byte("abcdefghijklmnopqrstuvwxyz0123456789") var i int r := bytes.NewReader(data) scanner := newScanner(r) for scanner.pos < atomic.LoadInt64(&scanner.end) { c := scanner.next() if scanner.readerErr != nil { t.Fatal(scanner.readerErr) } if c != data[i] {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
src/cmd/addr2line/addr2line_test.go
out, err := cmd.CombinedOutput() if err != nil { t.Fatalf("%v: %v\n%s", cmd, err, string(out)) } syms := make(map[string]string) scanner := bufio.NewScanner(bytes.NewReader(out)) for scanner.Scan() { f := strings.Fields(scanner.Text()) if len(f) < 3 { continue } syms[f[2]] = f[0] } if err := scanner.Err(); err != nil {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Sep 06 13:23:48 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
nbuf [chunk]byte // next internal buffer fillReq chan struct{} fillReady chan int64 readerErr error // underlying reader error, if any } func newScanner(r io.Reader) *scanner { sr := &scanner{ end: maxInt, fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() { var rpos int64 // total bytes read into buffer
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/config/config.go
} // Config - MinIO server config structure. type Config map[string]map[string]KVS // DelFrom - deletes all keys in the input reader. func (c Config) DelFrom(r io.Reader) error { scanner := bufio.NewScanner(r) for scanner.Scan() { // Skip any empty lines, or comment like characters text := scanner.Text() if text == "" || strings.HasPrefix(text, KvComment) { continue }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 37.7K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
// emitDepth from the provider io.Reader. // If emitDepth is < 0, values at every depth will be emitted. func NewDecoder(r io.Reader, emitDepth int) *Decoder { d := &Decoder{ scanner: newScanner(r), emitDepth: emitDepth, scratch: &scratch{data: make([]byte, 1024)}, metaCh: make(chan *MetaValue, 128), } if emitDepth < 0 { d.emitDepth = 0 d.emitRecursive = true } return d }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/common-main.go
func minioEnvironFromFile(envConfigFile string) ([]envKV, error) { f, err := Open(envConfigFile) if err != nil { return nil, err } defer f.Close() var ekvs []envKV scanner := bufio.NewScanner(f) for scanner.Scan() { ekv, err := parsEnvEntry(scanner.Text()) if err != nil { return nil, err } if ekv.Skip { // Skips empty lines continue } ekvs = append(ekvs, ekv)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 31.7K bytes - Viewed (0)