diff --git a/pkg/storage/stdio.go b/pkg/storage/stdio.go index 713a492fe6..7136eff016 100644 --- a/pkg/storage/stdio.go +++ b/pkg/storage/stdio.go @@ -20,7 +20,7 @@ func (*StdioEngine) Get(_ context.Context, u *URI) (Reader, error) { if u.Scheme != "stdio" || (u.Path != "stdin" && u.Path != "") { return nil, fmt.Errorf("cannot read from %q", u) } - return ¬SupportedReaderAt{io.NopCloser(os.Stdin)}, nil + return os.Stdin, nil } func (*StdioEngine) Put(ctx context.Context, u *URI) (io.WriteCloser, error) { diff --git a/sio/anyio/ztests/csup.yaml b/sio/anyio/ztests/csup.yaml index ba93f581ae..172b2030f2 100644 --- a/sio/anyio/ztests/csup.yaml +++ b/sio/anyio/ztests/csup.yaml @@ -1,12 +1,17 @@ script: | super -f csup -o f - super -s f + echo // standard input + super -s -c 'from "stdio:stdin"' < f inputs: - name: stdin - data: &stdin | + data: | {a:1} outputs: - name: stdout - data: *stdin + data: | + {a:1} + // standard input + {a:1} diff --git a/sio/anyio/ztests/parquet.yaml b/sio/anyio/ztests/parquet.yaml index 28421fac43..2ec6c836d9 100644 --- a/sio/anyio/ztests/parquet.yaml +++ b/sio/anyio/ztests/parquet.yaml @@ -1,12 +1,17 @@ script: | super -f parquet -o f - super -s f + echo // standard input + super -s -c 'from "stdio:stdin"' < f inputs: - name: stdin - data: &stdin | + data: | {a:1} outputs: - name: stdout - data: *stdin + data: | + {a:1} + // standard input + {a:1}