An AsyncIterator extensions that allows for filtering with Promise based filters.
npm install asyncfilteriteratorAn AsyncIterator extensions that allows for filtering with Promise based filters.
Use it like this:
``ts`
const oldStream: AsyncIterator
const filter: (item: T) => Promise
const newStream = new AsyncFilterIterator(filter, oldStream);
The only actual code is this:
`ts
import { AsyncIterator, TransformIterator } from 'asynciterator';
export class AsyncFilterIterator
constructor(public _filter: (item: T) => Promise
super({ source });
}
_transform(item: T, done: any) {
this._filter(item)
.then((result) => (result) ? this._push(item) : undefined)
.then(() => done())
.catch((error) => {
this.emit('error', error);
done();
});
};
}
``