change benchmark to use PassThrough.push

brianc · brianc · commit 3543bd86b64e · 2013-04-17T21:04:04.000-05:00
diff --git a/benchmark/simple-query-parsing.js b/benchmark/simple-query-parsing.js
@@ -2,8 +2,16 @@ var Client = require(__dirname + '/../lib/client');
 var buffers = require(__dirname + '/../test/test-buffers');
 require(__dirname + '/../test/unit/test-helper');
 
-var stream = new MemoryStream();
+var stream = new require('stream').PassThrough();
 stream.readyState = 'open';
+stream.write = function() {
+  //the stream used in the connection is
+  //already considered a duplex stream
+  //and its write method is used for writing
+  //out to postgres so for the benchmark
+  //ignore all writing so outgoing buffers
+  //do not get sent to the reader
+};
 var client = new Client({
   stream: stream
 });
@@ -52,7 +60,7 @@ client.connect(assert.calls(function() {
         assert.equal(res.rows.length, 9);
         done();
       });
-      buffers.forEach(stream.emit.bind(stream, 'data'));
+      buffers.forEach(stream.push.bind(stream));
     };
   };
 }));
