Filter implemented with a transform stream

gsantiago · Dec 1, 2021 · 2f70ec5 · 2f70ec5
1 parent 645ce77
commit 2f70ec5
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/src/filter.ts b/src/filter.ts
@@ -1,12 +1,11 @@
 import { Node } from '.'
-import { createDuplex } from './utils'
+import { Transform } from 'stream'
 
 export const filter = (callback: (node: Node) => boolean) =>
- createDuplex({
- write(chunk, _encoding, next) {
- if (callback(chunk)) {
- this.push(chunk)
- }
- next()
+ new Transform({
+ objectMode: true,
+ autoDestroy: false,
+ transform: function transform(chunk, _encoding, next) {
+ callback(chunk) ? next(null, chunk) : next()
  }
  })