bufferlist

Author: calvinmetcalf

build/files.js

@@ -171,6 +171,10 @@ const headRegexp = /(^module.exports = \w+;?)/m
     /Buffer\.((?:alloc)|(?:allocUnsafe)|(?:from))/g,
     `bufferShim.$1`
   ]
+  , internalDirectory = [
+    /require\('internal\/streams\/BufferList'\)/,
+    'require(\'./internal/streams/BufferList\')'
+  ]
 
 module.exports['_stream_duplex.js'] = [
     requireReplacement
@@ -215,6 +219,7 @@ module.exports['_stream_readable.js'] = [
   , eventEmittterListenerCountReplacement
   , bufferShimFix
   , bufferStaticMethods
+  , internalDirectory
 ]
 
 module.exports['_stream_transform.js'] = [
@@ -246,3 +251,7 @@ module.exports['_stream_writable.js'] = [
   , bufferShimFix
   , bufferStaticMethods
 ]
+module.exports['internal/streams/BufferList.js'] = [
+    bufferShimFix
+  , bufferStaticMethods
+]

build/test-replacements.js

@@ -264,3 +264,9 @@ module.exports['test-stream3-cork-uncork.js'] = module.exports['test-stream3-cor
     'assert.deepEqual(seen, expected);'
   ]
 ]
+module.exports['test-stream2-readable-from-list.js'] = [
+  [
+    /require\('internal\/streams\/BufferList'\)/,
+    'require(\'../../lib/internal/streams/BufferList\')'
+  ]
+]

lib/_stream_readable.js

@@ -51,7 +51,7 @@ if (debugUtil && debugUtil.debuglog) {
 }
 /*</replacement>*/
 
-var BufferList = require('internal/streams/BufferList');
+var BufferList = require('./internal/streams/BufferList');
 var StringDecoder;
 
 util.inherits(Readable, Stream);

lib/internal/streams/BufferList.js

@@ -0,0 +1,64 @@
+'use strict';
+
+var Buffer = require('buffer').Buffer;
+/*<replacement>*/
+var bufferShim = require('buffer-shims');
+/*</replacement>*/
+
+module.exports = BufferList;
+
+function BufferList() {
+  this.head = null;
+  this.tail = null;
+  this.length = 0;
+}
+
+BufferList.prototype.push = function (v) {
+  var entry = { data: v, next: null };
+  if (this.length > 0) this.tail.next = entry;else this.head = entry;
+  this.tail = entry;
+  ++this.length;
+};
+
+BufferList.prototype.unshift = function (v) {
+  var entry = { data: v, next: this.head };
+  if (this.length === 0) this.tail = entry;
+  this.head = entry;
+  ++this.length;
+};
+
+BufferList.prototype.shift = function () {
+  if (this.length === 0) return;
+  var ret = this.head.data;
+  if (this.length === 1) this.head = this.tail = null;else this.head = this.head.next;
+  --this.length;
+  return ret;
+};
+
+BufferList.prototype.clear = function () {
+  this.head = this.tail = null;
+  this.length = 0;
+};
+
+BufferList.prototype.join = function (s) {
+  if (this.length === 0) return '';
+  var p = this.head;
+  var ret = '' + p.data;
+  while (p = p.next) {
+    ret += s + p.data;
+  }return ret;
+};
+
+BufferList.prototype.concat = function (n) {
+  if (this.length === 0) return bufferShim.alloc(0);
+  if (this.length === 1) return this.head.data;
+  var ret = bufferShim.allocUnsafe(n >>> 0);
+  var p = this.head;
+  var i = 0;
+  while (p) {
+    p.data.copy(ret, i);
+    i += p.data.length;
+    p = p.next;
+  }
+  return ret;
+};

test/parallel/test-stream2-readable-from-list.js

@@ -5,7 +5,7 @@ var bufferShim = require('buffer-shims');
 require('../common');
 var assert = require('assert/');
 var fromList = require('../../lib/_stream_readable')._fromList;
-var BufferList = require('internal/streams/BufferList');
+var BufferList = require('../../lib/internal/streams/BufferList');
 
 // tiny node-tap lookalike.
 var tests = [];