update to new flow version

jillix · Mar 13, 2017 · 2552931 · 2552931
1 parent b9b7a8d
commit 2552931
Showing 1 changed file with 5 additions and 15 deletions.
diff --git a/lib/emit.js b/lib/emit.js
@@ -2,24 +2,14 @@
 
 // TODO create a suite to route flow sequences
 
-module.exports = function (scope, state, args = {}, data, stream, next) {
-
-    /*{
-        seqId: data.seqId (string)
-        package: data.data (object)
-        stream: data.stream (bool)
-    }*/
+module.exports = function (event, state, args, next) {
 
     // call flow sequnce
     let options;
-    if (typeof stream.pipe === "function") {
-        options = {objectMode: args.objectMode || stream._readableState.objectMode};
+    if (typeof event.output.pipe === "function") {
+        options = {objectMode: args.objectMode};// || stream._i._readableState.objectMode};
     }
 
-    const flow = scope.flow(args.seq || data.seq, args.data || data, options, next);
-    flow.on('error', next);
-    stream.done = next;
-    if (flow.pipe) {
-        stream = stream.pipe(flow);
-    }
+    data.seq = args.seq || data.seq;
+    next(null, data, event.output.pipe(scope.flow(data.seq, args.data || data, options)));
 };