cache_stream.js

'use strict';

const { Readable } = require('stream');

describe('CacheStream', () => {
  const CacheStream = require('../../lib/cache_stream');

  it('default', () => {
    const src = new Readable();
    const cacheStream = new CacheStream();
    const content = Buffer.from('test');

    src.push(content);
    src.push(null);
    src.pipe(cacheStream);

    cacheStream.on('finish', () => {
      cacheStream.getCache().should.eql(content);
    });
  });

  it('destroy', () => {
    const cacheStream = new CacheStream();
    cacheStream._cache = [Buffer.alloc(1)];

    cacheStream.destroy();
    cacheStream._cache.should.have.length(0);
  });
});