fixed issue #29

impronunciable · May 9, 2013 · 21ebb9e · 21ebb9e
1 parent 426d412
commit 21ebb9e
Showing 1 changed file with 5 additions and 10 deletions.
diff --git a/lib/tuiter.js b/lib/tuiter.js
@@ -143,25 +143,20 @@ Tuiter.prototype.handleStream = function(req, endpoint, params, callback) {
   var args = stream.args = arguments;
   stream.emitAPIEvents();
   stream.autoReconnect();
-
-  req.pipe(stream);
-  req.req.on('response', function(res){
-    res.setEncoding('utf8');
-  });
-
+
+	req.pipe(stream);
   callback(stream);
 
   stream.on('end', function(){ 
-    if(stream.res) stream.res.removeAllListeners('end');
     stream.end();
     req = stream = null; 
   });
 
   stream.on('reconnect', function(new_args){ 
     params = new_args || params; 
-    if(stream.res) stream.res.removeAllListeners('end');
-    req = stream = null; 
-    APIRequest.call(self, endpoint, params, callback); 
+		stream.emit('end');
+		preProcess(params);
+    APIRequest.call(self, endpoint, params, callback);
   });
 };