From a8dc68cdcc7169a46e8e65cbc00a7db57d62e908 Mon Sep 17 00:00:00 2001 From: Micah Riggan Date: Mon, 28 Jan 2019 10:13:08 -0500 Subject: [PATCH] adding wait function --- packages/bitcore-node/src/services/p2p.ts | 5 +++-- packages/bitcore-node/src/utils/wait.ts | 3 +++ 2 files changed, 6 insertions(+), 2 deletions(-) create mode 100644 packages/bitcore-node/src/utils/wait.ts diff --git a/packages/bitcore-node/src/services/p2p.ts b/packages/bitcore-node/src/services/p2p.ts index 1a491dffd06..0a233ae3550 100644 --- a/packages/bitcore-node/src/services/p2p.ts +++ b/packages/bitcore-node/src/services/p2p.ts @@ -8,6 +8,7 @@ import { StateStorage } from '../models/state'; import { SpentHeightIndicators } from '../types/Coin'; import os from 'os'; import { Config, ConfigService } from './config'; +import { wait } from "../utils/wait"; const Chain = require('../chain'); export class P2pManager { @@ -230,7 +231,7 @@ export class P2pWorker { }); while (!received) { this.pool.sendMessage(this.messages.GetHeaders({ starts: candidateHashes })); - await new Promise(resolve => setTimeout(resolve, 1000)); + await wait(1000); } }); } @@ -246,7 +247,7 @@ export class P2pWorker { }); while (!received) { this.pool.sendMessage(this.messages.GetData.forBlock(hash)); - await new Promise(resolve => setTimeout(resolve, 1000)); + await wait(1000); } }); } diff --git a/packages/bitcore-node/src/utils/wait.ts b/packages/bitcore-node/src/utils/wait.ts new file mode 100644 index 00000000000..13da0a42361 --- /dev/null +++ b/packages/bitcore-node/src/utils/wait.ts @@ -0,0 +1,3 @@ +export async function wait(time: number) { + return new Promise(resolve => setTimeout(resolve, time)); +}