import { Readable } from "stream"; class AnswerStream extends Readable { private source: Readable public constructor(params: { source: Readable }) { super() const { source } = params this.source = source } _read(n) { const result = this.source.read(n) console.log(result) } } export { AnswerStream }