Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion book/super-example/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ func run(opts opts) wasm.Promise {
zctx := super.NewContext()
var readers []sio.Reader
if r != nil {
rc, err := anyio.NewReaderWithOpts(zctx, r, anyio.ReaderOpts{Format: opts.InputFormat})
rc, err := anyio.NewReader(zctx, r, anyio.ReaderOpts{Format: opts.InputFormat})
if err != nil {
return "", err
}
Expand Down
2 changes: 1 addition & 1 deletion service/handlers.go
Original file line number Diff line number Diff line change
Expand Up @@ -457,7 +457,7 @@ func handleBranchLoad(c *Core, w *ResponseWriter, r *Request) {
BSUP: bsupio.ReaderOpts{Validate: true},
}
sctx := super.NewContext()
zrc, err := anyio.NewReaderWithOpts(sctx, reader, opts)
zrc, err := anyio.NewReader(sctx, reader, opts)
if err != nil {
w.Error(srverr.ErrInvalid(err))
return
Expand Down
2 changes: 1 addition & 1 deletion service/request.go
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ func (r *Request) Unmarshal(w *ResponseWriter, body any, templates ...any) bool
if !ok {
return false
}
zrc, err := anyio.NewReaderWithOpts(super.NewContext(), r.Body, anyio.ReaderOpts{Format: format})
zrc, err := anyio.NewReader(super.NewContext(), r.Body, anyio.ReaderOpts{Format: format})
if err != nil {
w.Error(srverr.ErrInvalid(err))
return false
Expand Down
2 changes: 1 addition & 1 deletion sio/anyio/file.go
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ func NewFile(sctx *super.Context, rc io.ReadCloser, path string, opts ReaderOpts
if err != nil {
return nil, err
}
zr, err := NewReaderWithOpts(sctx, r, opts)
zr, err := NewReader(sctx, r, opts)
if err != nil {
return nil, err
}
Expand Down
6 changes: 1 addition & 5 deletions sio/anyio/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,7 @@ type ReaderOpts struct {
CSV csvio.ReaderOpts
}

func NewReader(sctx *super.Context, r io.Reader) (sio.ReadCloser, error) {
return NewReaderWithOpts(sctx, r, ReaderOpts{})
}

func NewReaderWithOpts(sctx *super.Context, r io.Reader, opts ReaderOpts) (sio.ReadCloser, error) {
func NewReader(sctx *super.Context, r io.Reader, opts ReaderOpts) (sio.ReadCloser, error) {
if opts.Format != "" && opts.Format != "auto" {
return lookupReader(sctx, r, opts)
}
Expand Down
6 changes: 3 additions & 3 deletions spq_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ func loadZTestInputsAndOutputs(ztestDirs map[string]struct{}) (map[string]string
// isValid returns true if and only if s can be read fully without error by
// anyio and contains at least one value.
func isValid(s string) bool {
zrc, err := anyio.NewReader(super.NewContext(), strings.NewReader(s))
zrc, err := anyio.NewReader(super.NewContext(), strings.NewReader(s), anyio.ReaderOpts{})
if err != nil {
return false
}
Expand Down Expand Up @@ -134,7 +134,7 @@ func runAllBoomerangs(t *testing.T, format string, data map[string]string) {
func runOneBoomerang(t *testing.T, format, data string) {
// Create an auto-detecting reader for data.
sctx := super.NewContext()
dataReadCloser, err := anyio.NewReader(sctx, strings.NewReader(data))
dataReadCloser, err := anyio.NewReader(sctx, strings.NewReader(data), anyio.ReaderOpts{})
require.NoError(t, err)
defer dataReadCloser.Close()

Expand Down Expand Up @@ -168,7 +168,7 @@ func runOneBoomerang(t *testing.T, format, data string) {
}

// Create a reader for baseline.
baselineReader, err := anyio.NewReaderWithOpts(super.NewContext(), bytes.NewReader(baseline.Bytes()), anyio.ReaderOpts{
baselineReader, err := anyio.NewReader(super.NewContext(), bytes.NewReader(baseline.Bytes()), anyio.ReaderOpts{
Format: format,
BSUP: bsupio.ReaderOpts{
Validate: true,
Expand Down
2 changes: 1 addition & 1 deletion ztest/ztest.go
Original file line number Diff line number Diff line change
Expand Up @@ -539,5 +539,5 @@ func newInputReader(sctx *super.Context, input string, flags []string) (sio.Read
if err != nil {
return nil, err
}
return anyio.NewReaderWithOpts(sctx, r, inflags.ReaderOpts)
return anyio.NewReader(sctx, r, inflags.ReaderOpts)
}
Loading