2.0.0
fixes #4
Added
- docs(README): added pretty good documentation
- transformers: HeaderSkipper & LineTransformer (separated the concerns)
- async Iteration: implemented
Symbol.asyncIteratorforfor await...of. - pipeline Architecture:
pipe()now generates independentPassThroughandTransformchains per call to support natural backpressure and sequential piping.
Changed
- style(exnext): converted
MessageStreaminternal state (#queue,#fd,#bufferMax, etc.) to private class fields. - style(esnext): replaced
write_completepolling with a_write_completeevent listener. - source delegation:
pause()andresume()now delegate directly to the active#currentSource.
Fixed
- error propagation: ensure disk I/O errors correctly propagate via
this.emit('error') - race conditions: updated
destroy()to close file descriptors before unlinking to preventEBADFerrors.