1
This commit is contained in:
parent
f7e0bfe55c
commit
4f5653d398
@ -36,7 +36,7 @@ class BcSpider extends BaseTask {
|
|||||||
events.push(event);
|
events.push(event);
|
||||||
this.createPullBcEventService(net, event);
|
this.createPullBcEventService(net, event);
|
||||||
});
|
});
|
||||||
this.outputProgressInfo();
|
this.outputProgressInfo(net, events);
|
||||||
}
|
}
|
||||||
|
|
||||||
createPullBcEventService(net, event) {
|
createPullBcEventService(net, event) {
|
||||||
@ -47,8 +47,15 @@ class BcSpider extends BaseTask {
|
|||||||
return pullBcEventService;
|
return pullBcEventService;
|
||||||
}
|
}
|
||||||
|
|
||||||
async outputProgressInfo() {
|
async outputProgressInfo(net, events) {
|
||||||
|
let count = 0;
|
||||||
while (true) {
|
while (true) {
|
||||||
|
log.info('----------------------------------------------------------net_id:' + net['net_id'] + ' %d' + count);
|
||||||
|
events.forEach
|
||||||
|
(
|
||||||
|
(event) => {
|
||||||
|
}
|
||||||
|
);
|
||||||
await utils.sleep(1000 * 10);
|
await utils.sleep(1000 * 10);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user