16 lines
325 B
JavaScript
16 lines
325 B
JavaScript
|
import { default as concat } from 'concat-stream';
|
||
|
|
import { default as once } from 'once';
|
||
|
|
|
||
|
|
export default function collect(stream, opts, fn) {
|
||
|
|
if (typeof opts === 'function') {
|
||
|
|
fn = opts;
|
||
|
|
opts = {};
|
||
|
|
}
|
||
|
|
fn = once(fn);
|
||
|
|
stream.on('error', fn);
|
||
|
|
stream.pipe(concat(opts, data => {
|
||
|
|
fn(null, data);
|
||
|
|
}));
|
||
|
|
};
|
||
|
|
|