import Task from 'task-flow-rollback';
const task = new Task();

task.pipe(async (value, rejected) => {
    await new Promise((resolve, reject) => {
        fs.writeFile('./test.json', JSON.stringify({ a: 1 }), err => {
            if (err) return reject(err);
            resolve();
        });
    })
    rejected(async () => {
        fs.unlink('./test.json', err => {
            if (err) throw new Error(err);
        });
    });
    return true;
});
// ... 这里可以写更多pipe流程
task.pipe(async value => {
    console.log('I will throw an error', 'and last value is:', value);
    throw new Error('error');
})

task.pipe((value, reject) => {
    fs.writeFileSync('./test.json', JSON.stringify({ a: 1 }));
    reject(() => fs.unlinkSync('./test.json'));
    return true;
});
// ... 这里可以写更多pipe流程
task.pipe(value => {
    console.log('I will throw an error', 'and last value is:', value);
    throw new Error('error');
})