dehydrater

Dehydrater

Promise queue handler.

npm install dehydrater --save

Dehydrater.transaction

Dehydrater.transaction({n: 1}, next => {
  next(async (obj) => {
    await wait(100);
    return {n: obj.n + 1};
  });
 
  next(async (obj) => {
    await wait(100);
    return {n: obj.n + 2};
  });
 
  next(async (obj) => {
    await wait(100);
    return {n: obj.n + 3};
  });
 
}).then(result => {
  console.log(result); // {n: 7}
});

Dehydrater.startDehydrate(target)

const d = Dehydrater.create();
const {next, promise} = d.startDehydrate({n: 1});
 
next(async (obj) => {
  await wait(100);
  return {n: obj.n + 1};
});
 
next(async (obj) => {
  await wait(100);
  return {n: obj.n + 2};
});
 
next(async (obj) => {
  await wait(100);
  return {n: obj.n + 3};
});
 
promise.then(data => {
  console.log(data); // {n: 7}
});

LICENSE

MIT