All files / lib/stream promises.js

100% Statements 39/39
100% Branches 13/13
100% Functions 2/2
100% Lines 39/39

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 406x 6x 6x 6x 6x 6x 6x 6x 6x 3x 3x 3x 3x 3x 1x 2x 2x 2x 3x 3x 3x 6x 3x 3x 3x 3x 3x 1x 2x 2x 2x 3x 3x 3x 6x 6x 6x 6x 6x  
'use strict';
 
const {
  Promise,
} = primordials;
 
let pl;
let eos;
 
function pipeline(...streams) {
  if (!pl) pl = require('internal/streams/pipeline');
  return new Promise((resolve, reject) => {
    pl(...streams, (err, value) => {
      if (err) {
        reject(err);
      } else {
        resolve(value);
      }
    });
  });
}
 
function finished(stream, opts) {
  if (!eos) eos = require('internal/streams/end-of-stream');
  return new Promise((resolve, reject) => {
    eos(stream, opts, (err) => {
      if (err) {
        reject(err);
      } else {
        resolve();
      }
    });
  });
}
 
module.exports = {
  finished,
  pipeline,
};