0.2.1

index.js

@@ -66,6 +66,7 @@ module.exports = function simpleSinkStream(_options) {
 					return attemptRead();
 				}).catch(isEndOfStream, (error) => {
 					/* Don't attempt to do another read, we're done.  */
+					return Promise.try(() => {
 						if (!onEndCalled && onEnd != null) {
 							onEndCalled = true;
 							
@@ -77,10 +78,11 @@ module.exports = function simpleSinkStream(_options) {
 								}
 							});
 						}
-
+					}).then(() => {
 						return resultBuffer.maybeRead(() => {
 							throw error;
 						});
+					});
 				}).catch((error) => !isAborted(error), (error) => {
 					return Promise.try(() => {
 						return source.abort(error);

package.json

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