add a new global method CLEANUP for safe cleaning streams

petersirka · petersirka · commit 35e4b32f028f · 2015-07-21T12:20:55.000+02:00
diff --git a/index.js b/index.js
@@ -175,6 +175,14 @@ global.DESTROY = function(stream) {
 	framework_internal.destroyStream(stream);
 };
 
+global.CLEANUP = function(stream, callback) {
+	FINISHED(stream, function() {
+		if (callback)
+			callback();
+		DESTROY(stream);
+	});
+};
+
 global.SUCCESS = function(success, value) {
 
 	var err;
