All files / lib/stream promises.js

38.46% Statements 15/39
100% Branches 1/1
0% Functions 0/2
38.46% Lines 15/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 4091x 91x 91x 91x 91x 91x 91x 91x 91x                         91x                         91x 91x 91x 91x 91x  
'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,
};