diff --git a/internal/readablestream/writer.go b/internal/readablestream/writer.go index 7047a55..e74772e 100644 --- a/internal/readablestream/writer.go +++ b/internal/readablestream/writer.go @@ -78,8 +78,8 @@ func (rs *Writer) Write(b []byte) (int, error) { } func (rs *Writer) Close() error { - rs.controller.Call("close") - return nil + _, err := rs.controller.Call("close") + return err } func (rs *Writer) Context() context.Context {