MCPcopy Create free account
hub / github.com/brimdata/super / NewReader

Function NewReader

sio/jsupio/reader.go:30–39  ·  view source on GitHub ↗
(sctx *super.Context, reader io.Reader)

Source from the content-addressed store, hash-verified

28}
29
30func NewReader(sctx *super.Context, reader io.Reader) *Reader {
31 s := bufio.NewScanner(reader)
32 s.Buffer(make([]byte, ReadSize), MaxLineSize)
33 return &Reader{
34 scanner: s,
35 sctx: sctx,
36 decoder: make(decoder),
37 builder: scode.NewBuilder(),
38 }
39}
40
41func (r *Reader) Read() (*super.Value, error) {
42 e := func(err error) error {

Callers 3

boomerangJSUPFunction · 0.92
NewReaderFunction · 0.92
lookupReaderFunction · 0.92

Calls 2

NewBuilderFunction · 0.92
NewScannerMethod · 0.65

Tested by 1

boomerangJSUPFunction · 0.74