feature(spawnify) add write

Author: coderaiser

lib/spawnify.js

@@ -42,8 +42,6 @@
     function Spawnify(command, options) {
         var self = this;
 
-        this._child = null;
-        
         EventEmitter.call(this);
 
         process.nextTick(function() {
@@ -103,8 +101,7 @@
     };
 
     Spawnify.prototype._set = function set(type, command, options) {
-        var args, error,
-            self    = this;
+        var args, error, child;
 
         check(arguments, ['type', 'command', 'options']);
 
@@ -114,7 +111,7 @@
 
         case 'exec':
             error   = tryCatch(function() {
-                self._child = exec(command, options);
+                child = exec(command, options);
             });
             break;
 
@@ -123,36 +120,45 @@
             command = args.shift();
 
             error   = tryCatch(function() {
-                self._child = spawn(command, args, options);
+                child = spawn(command, args, options);
             });
             break;
         }
 
+        child.stderr.setEncoding('utf-8');
+        child.stdout.setEncoding('utf-8');
+        child.stdin.setEncoding('utf-8');
+        
         if (error) {
             this._emit('error', newLine(error));
         } else {
+            this._setListeners(child);
+            
             this.on('kill', function(code) {
-                self._child.kill(code);
+                child.kill(code);
             });
 
-            this._emit('start');
+            this.on('write', function(data) {
+                child.stdin.write(data);
+            });
 
-            this._setListeners(this._child);
+            this._emit('start');
         }
     };
 
     Spawnify.prototype.kill = function(code) {
         this._emit('kill', code);
     };
 
+    Spawnify.prototype.write = function(data) {
+        this._emit('write', data);
+    };
+    
     Spawnify.prototype._setListeners = function setListeners(child) {
         var self = this;
 
         check(arguments, ['child']);
 
-        child.stderr.setEncoding('utf8');
-        child.stdout.setEncoding('utf8');
-        
         child.stdout.on('data', function(data) {
             self._emit('data', data);
         });