Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for NewScanner (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top