Compare commits

...

2 Commits

@ -66,20 +66,22 @@ module.exports = function simpleSinkStream(_options) {
return attemptRead(); return attemptRead();
}).catch(isEndOfStream, (error) => { }).catch(isEndOfStream, (error) => {
/* Don't attempt to do another read, we're done. */ /* Don't attempt to do another read, we're done. */
if (!onEndCalled && onEnd != null) { return Promise.try(() => {
onEndCalled = true; if (!onEndCalled && onEnd != null) {
onEndCalled = true;
return Promise.try(() => {
return onEnd(); return Promise.try(() => {
}).then((result) => { return onEnd();
if (result !== undefined) { }).then((result) => {
resultBuffer.push(result); if (result !== undefined) {
} resultBuffer.push(result);
}
});
}
}).then(() => {
return resultBuffer.maybeRead(() => {
throw error;
}); });
}
return resultBuffer.maybeRead(() => {
throw error;
}); });
}).catch((error) => !isAborted(error), (error) => { }).catch((error) => !isAborted(error), (error) => {
return Promise.try(() => { return Promise.try(() => {

@ -1,6 +1,6 @@
{ {
"name": "@promistream/simple-sink", "name": "@promistream/simple-sink",
"version": "0.2.0", "version": "0.2.1",
"main": "index.js", "main": "index.js",
"repository": "http://git.cryto.net/promistream/simple-sink.git", "repository": "http://git.cryto.net/promistream/simple-sink.git",
"author": "Sven Slootweg <admin@cryto.net>", "author": "Sven Slootweg <admin@cryto.net>",

Loading…
Cancel
Save