import type { TransformCallback } from 'node:stream'
import { Transform } from 'node:stream'
import { removeLastListener } from './utils.js'
export default class RunnerStream extends Transform {
constructor () {
super()
* Remove events that are automatically created by Writable stream
*/
this.on('pipe', () => {
removeLastListener(this, 'close')
removeLastListener(this, 'drain')
removeLastListener(this, 'error')
removeLastListener(this, 'finish')
removeLastListener(this, 'unpipe')
})
}
_transform (chunk: Buffer, _encoding: BufferEncoding, callback: TransformCallback): void {
callback(undefined, chunk)
}
_final (callback: (error?: Error | undefined) => void): void {
this.unpipe()
callback()
}
}
