benchmark: improve readability of net benchmarks

PR-URL: #10446 Reviewed-By: James M Snell <jasnell@gmail.com>
nodejs · Jan 5, 2017 · f955c73 · f955c73
1 parent d43b144
commit f955c73
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 30 deletions.
diff --git a/benchmark/net/net-c2s.js b/benchmark/net/net-c2s.js
@@ -65,8 +65,17 @@ Writer.prototype.emit = function() {};
 Writer.prototype.prependListener = function() {};
 
 
+function flow() {
+  var dest = this.dest;
+  var res = dest.write(chunk, encoding);
+  if (!res)
+    dest.once('drain', this.flow);
+  else
+    process.nextTick(this.flow);
+}
+
 function Reader() {
-  this.flow = this.flow.bind(this);
+  this.flow = flow.bind(this);
   this.readable = true;
 }
 
@@ -76,15 +85,6 @@ Reader.prototype.pipe = function(dest) {
   return dest;
 };
 
-Reader.prototype.flow = function() {
-  var dest = this.dest;
-  var res = dest.write(chunk, encoding);
-  if (!res)
-    dest.once('drain', this.flow);
-  else
-    process.nextTick(this.flow);
-};
-
 
 function server() {
   var reader = new Reader();

diff --git a/benchmark/net/net-pipe.js b/benchmark/net/net-pipe.js
@@ -65,8 +65,17 @@ Writer.prototype.emit = function() {};
 Writer.prototype.prependListener = function() {};
 
 
+function flow() {
+  var dest = this.dest;
+  var res = dest.write(chunk, encoding);
+  if (!res)
+    dest.once('drain', this.flow);
+  else
+    process.nextTick(this.flow);
+}
+
 function Reader() {
-  this.flow = this.flow.bind(this);
+  this.flow = flow.bind(this);
   this.readable = true;
 }
 
@@ -76,15 +85,6 @@ Reader.prototype.pipe = function(dest) {
   return dest;
 };
 
-Reader.prototype.flow = function() {
-  var dest = this.dest;
-  var res = dest.write(chunk, encoding);
-  if (!res)
-    dest.once('drain', this.flow);
-  else
-    process.nextTick(this.flow);
-};
-
 
 function server() {
   var reader = new Reader();

diff --git a/benchmark/net/net-s2c.js b/benchmark/net/net-s2c.js
@@ -65,8 +65,17 @@ Writer.prototype.emit = function() {};
 Writer.prototype.prependListener = function() {};
 
 
+function flow() {
+  var dest = this.dest;
+  var res = dest.write(chunk, encoding);
+  if (!res)
+    dest.once('drain', this.flow);
+  else
+    process.nextTick(this.flow);
+}
+
 function Reader() {
-  this.flow = this.flow.bind(this);
+  this.flow = flow.bind(this);
   this.readable = true;
 }
 
@@ -76,15 +85,6 @@ Reader.prototype.pipe = function(dest) {
   return dest;
 };
 
-Reader.prototype.flow = function() {
-  var dest = this.dest;
-  var res = dest.write(chunk, encoding);
-  if (!res)
-    dest.once('drain', this.flow);
-  else
-    process.nextTick(this.flow);
-};
-
 
 function server() {
   var reader = new Reader();