|
@@ -17,8 +17,8 @@ const reduceStream = (options, initial) => {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
const stream = new Writable(
|
|
const stream = new Writable(
|
|
|
- Object.assign({}, {objectMode: true}, options, {
|
|
|
|
|
- write(chunk, encoding, callback) {
|
|
|
|
|
|
|
+ Object.assign({objectMode: true}, options, {
|
|
|
|
|
+ write(chunk, _, callback) {
|
|
|
const result = reducer.call(this, this.accumulator, chunk);
|
|
const result = reducer.call(this, this.accumulator, chunk);
|
|
|
if (result && typeof result.then == 'function') {
|
|
if (result && typeof result.then == 'function') {
|
|
|
result.then(
|
|
result.then(
|