example.js

const { Operation } = require('./src/Operation');
const { BlockOperation } = require('./src/BlockOperation');
const { OperationQueue } = require('./src/OperationQueue');

const axios = require('axios');

class DownloadDataOperation extends Operation {

    async run() {
        try {
            const response = await axios.get('https://samples.openweathermap.org/data/2.5/weather?lat=35&lon=139&appid=b6907d289e10d714a6e88b30761fae22');
            const data = response.data;
            return this.id;
        } catch (e) {
            this.cancel();
        }
    }
}

class TimeOutOperation extends Operation {

    constructor(id = null, time = 1000) {
        super(id);
        this.time = time; 
    }

    run() {
        return new Promise((resolve, reject) => {
            setTimeout(() => {
                resolve();
            }, this.time);
        })
    }

}

const blockOperation6 = new BlockOperation(6, async () => {
    const response = await axios.get('https://samples.openweathermap.org/data/2.5/weather?lat=35&lon=139&appid=b6907d289e10d714a6e88b30761fae22');
    const data = response.data;
    return data;
});

const operation = new DownloadDataOperation(1);
const operation2 = new DownloadDataOperation(2);
const operation3 = new DownloadDataOperation(3);
const operation4 = new TimeOutOperation(4, 1000);
const operation5 = new TimeOutOperation(5, 1000);
const operation7 = new TimeOutOperation(7, 1000);
const operation8 = new TimeOutOperation(8, 1000);

operation.dependencies = [operation2, operation7];
// operation2.dependencies = [operation4, operation8];
// operation3.dependencies = [operation, operation5, operation2];
// operation4.dependencies = [operation5, blockOperation6];
// operation5.dependencies = [blockOperation6];
// operation8.dependencies = [operation7];

blockOperation6.completionCallback = (operation) => {
    operation5.data = operation.result;
}

// operation2.dependencies = [operation3];

// operation.on('start', op => {
//     console.log('start', op.id);
// });
// operation.on('done', op => {
//     console.log('done', op.id);
// });
// operation.on('error', (err, op) => {
//     console.log('error', op.id);
// });
// operation.completionCallback = () => {
//     // console.log('done')
// }

const operationQueue = new OperationQueue();
operationQueue.maximumConcurrentOperations = 10;
// operationQueue.addOperation(operation);
// operationQueue.addOperation(operation3);
// operationQueue.completionCallback = () => {
//     console.log('queue done');
//     console.log(operationQueue.totalTime);
// };
(new Operation()).start().catch(e => {});
// operationQueue.addOperations([operation4, operation5, operation7, operation8])
//     .then(result => {
//         console.log(result)
//     })
//     .catch(e => {
//         console.log(e)
//     });

// operation4.cancel();
// operation.start()
//     .then(() => {
//         console.log('123');
//     });