1
This commit is contained in:
parent
ff55e15735
commit
72c7004f7d
@ -8,7 +8,6 @@ class PullBcEvent extends BaseService {
|
|||||||
|
|
||||||
async init(bc, net, event) {
|
async init(bc, net, event) {
|
||||||
this.conn = conn;
|
this.conn = conn;
|
||||||
this.cb = cb;
|
|
||||||
this.lastBlockNumber = 0;
|
this.lastBlockNumber = 0;
|
||||||
this.bc = bc;
|
this.bc = bc;
|
||||||
this.net = net;
|
this.net = net;
|
||||||
@ -66,7 +65,6 @@ class PullBcEvent extends BaseService {
|
|||||||
for (let i in events) {
|
for (let i in events) {
|
||||||
while (true) {
|
while (true) {
|
||||||
try {
|
try {
|
||||||
await this.cb(events[i]);
|
|
||||||
await this.saveToDb(events[i]);
|
await this.saveToDb(events[i]);
|
||||||
break;
|
break;
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user