[feature] implement _write and _read

http-party · Aug 9, 2013 · 6a4294c · 6a4294c
1 parent 4f24664
commit 6a4294c
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/lib/caronte/streams/proxy.js b/lib/caronte/streams/proxy.js
@@ -29,12 +29,18 @@ ProxyStream.prototype.onFinish = function() {
 
 }
 
-ProxyStream.prototype.onResponse = function() {
-
+ProxyStream.prototype.onResponse = function(proxyRes) {
+  this.proxyRes = proxyRes;
 }
 
-ProxyStream.prototype._read = function() {}
+ProxyStream.prototype._write = function(chunk, encoding, callback) {
+  this.proxyReq.write(chunk, encoding, callback);
+};
+
+ProxyStream.prototype._read = function(size) {
+  var chunk = (this.proxyRes ? this.proxyRes.read(size) : '') || '';
 
-ProxyStream.prototype._write = function() {}
+  this.push(chunk);
+};
 
 require('util').inherits(ForwardStream, Duplex);