it.skip('should mock ' + modName + '.request({url: "/bar/foo"}) with stream 500ms response delay',
      function(done) {
        const mockResData = new ChunkStream([ 'mock data with regex url', '哈哈' ]);
        const mockResHeaders = { server: 'mock server' };
        mm[modName].request({ url: '/bar/foo' }, mockResData, mockResHeaders, 500);

        const start = Date.now();
        mod.get({
          host: 'npmjs.org',
          path: '/bar/foo',
        }, function(res) {
          res.headers.should.eql(mockResHeaders);
          res.setEncoding('utf8');
          let body = '';
          res.on('data', function(chunk) {
            chunk.should.be.a.String;
            body += chunk;
          });
          res.on('end', function() {
            const use = Date.now() - start;
            body.should.equal([ 'mock data with regex url', '哈哈' ].join(''));
            use.should.above(490);
            done();
          });
        });
      });

'use strict';

/**
 * Module dependencies.
 */

var Readable = require('stream').Readable;
var util = require('util');
util.inherits(ChunkStream, Readable);

function ChunkStream(chunks, options) {
 chunks.push(null);
  Readable.call(this, options);
  this._chunks = chunks;
}

ChunkStream.prototype._read = function() {
  this.push(this._chunks.shift());
};

module.exports = ChunkStream;

'use strict';

/**
 * Module dependencies.
 */

var Readable = require('stream').Readable;
var util = require('util');
util.inherits(ChunkStream, Readable);

function ChunkStream(chunks, options) {
  Readable.call(this, options);
  this._chunks = chunks;
}

ChunkStream.prototype._read = function() {
  if (this._chunks.length === 0) {
    return this.push(null);
  }
  this.push(this._chunks.shift());
};

module.exports = ChunkStream;