diff --git a/interfaces/kits/ts/streamrw/src/streamrw.ts b/interfaces/kits/ts/streamrw/src/streamrw.ts index d3f3e35dddbec2ee2ded7b4e8f5f5fe1bc2a712d..86ec05340ad769299b3f018f2f0fdb7cba06c09f 100644 --- a/interfaces/kits/ts/streamrw/src/streamrw.ts +++ b/interfaces/kits/ts/streamrw/src/streamrw.ts @@ -96,6 +96,9 @@ class ReadStream extends stream.Readable { this.offset = this.offset - readSize + readOut; this.push(null); } + }) + .finally(() => { + this.stream?.flush(); }); } }