Function testWithCompression

test/parallel/test-stream-iter-readable-interop.js:391–407

()

// =============================================================================

async function testWithCompression() {
  const {
    compressGzip,
    decompressGzip,
  } = require('zlib/iter');

  const readable = new Readable({
    read() {
      this.push(Buffer.from('compress me via classic Readable'));
      this.push(null);
    },
  });

  const compressed = pull(readable, compressGzip());
  const result = await text(pull(compressed, decompressGzip()));
  assert.strictEqual(result, 'compress me via classic Readable');
}

// =============================================================================
// Object-mode Readable: error propagation