aboutsummaryrefslogtreecommitdiffstats
path: root/packages/instant/src/util/heartbeater.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/instant/src/util/heartbeater.ts')
-rw-r--r--packages/instant/src/util/heartbeater.ts35
1 files changed, 0 insertions, 35 deletions
diff --git a/packages/instant/src/util/heartbeater.ts b/packages/instant/src/util/heartbeater.ts
deleted file mode 100644
index e700d489e..000000000
--- a/packages/instant/src/util/heartbeater.ts
+++ /dev/null
@@ -1,35 +0,0 @@
-import { intervalUtils } from '@0x/utils';
-import * as _ from 'lodash';
-
-type HeartbeatableFunction = () => Promise<void>;
-export class Heartbeater {
- private _intervalId?: NodeJS.Timer;
- private readonly _performImmediatelyOnStart: boolean;
- private readonly _performFunction: HeartbeatableFunction;
-
- public constructor(performingFunctionAsync: HeartbeatableFunction, performImmediatelyOnStart: boolean) {
- this._performFunction = performingFunctionAsync;
- this._performImmediatelyOnStart = performImmediatelyOnStart;
- }
-
- public start(intervalTimeMs: number): void {
- if (!_.isUndefined(this._intervalId)) {
- throw new Error('Heartbeat is running, please stop before restarting');
- }
-
- if (this._performImmediatelyOnStart) {
- // tslint:disable-next-line:no-floating-promises
- this._performFunction();
- }
-
- // tslint:disable-next-line:no-unbound-method
- this._intervalId = intervalUtils.setAsyncExcludingInterval(this._performFunction, intervalTimeMs, _.noop);
- }
-
- public stop(): void {
- if (this._intervalId) {
- intervalUtils.clearInterval(this._intervalId);
- }
- this._intervalId = undefined;
- }
-}