Now emitting end, decreased timeout to 5 seconds

Author: zubairov

lib/actions/write.js

@@ -57,12 +57,13 @@ function processAction(msg) {
 
             yield init();
         });
-    }, 10000);
+    }, 5000);
 
     console.log('Writing to stream', msg.body);
 
     stringifier.write(msg.body);
     rowCount++;
+    this.emit('end');
 }
 
 /**