Sha256: ce03f946827805d3f6d7f67b06191a386a8a5774d33909b01f2583809ebeaf50
Contents?: true
Size: 677 Bytes
Versions: 57
Compression:
Stored size: 677 Bytes
Contents
'use strict';
const {Transform} = require('stream');
class ObjectTransform extends Transform {
constructor() {
super({
objectMode: true
});
}
}
class FilterStream extends ObjectTransform {
constructor(filter) {
super();
this._filter = filter;
}
_transform(data, encoding, callback) {
if (this._filter(data)) {
this.push(data);
}
callback();
}
}
class UniqueStream extends ObjectTransform {
constructor() {
super();
this._pushed = new Set();
}
_transform(data, encoding, callback) {
if (!this._pushed.has(data)) {
this.push(data);
this._pushed.add(data);
}
callback();
}
}
module.exports = {
FilterStream,
UniqueStream
};
Version data entries
57 entries across 57 versions & 2 rubygems