1 files changed, 59 insertions, 59 deletions
diff --git a/packages/0x.js/src/order_watcher/expiration_watcher.ts b/packages/0x.js/src/order_watcher/expiration_watcher.ts
index 00b62162d..a08de94c0 100644
--- a/packages/0x.js/src/order_watcher/expiration_watcher.ts
+++ b/packages/0x.js/src/order_watcher/expiration_watcher.ts
@@ -13,63 +13,63 @@ const DEFAULT_ORDER_EXPIRATION_CHECKING_INTERVAL_MS = 50;
  * It stores them in a min heap by expiration time and checks for expired ones every `orderExpirationCheckingIntervalMs`
  */
 export class ExpirationWatcher {
-    private _orderHashByExpirationRBTree: RBTree<string>;
-    private _expiration: { [orderHash: string]: BigNumber } = {};
-    private _orderExpirationCheckingIntervalMs: number;
-    private _expirationMarginMs: number;
-    private _orderExpirationCheckingIntervalIdIfExists?: NodeJS.Timer;
-    constructor(expirationMarginIfExistsMs?: number, orderExpirationCheckingIntervalIfExistsMs?: number) {
-        this._expirationMarginMs = expirationMarginIfExistsMs || DEFAULT_EXPIRATION_MARGIN_MS;
-        this._orderExpirationCheckingIntervalMs =
-            expirationMarginIfExistsMs || DEFAULT_ORDER_EXPIRATION_CHECKING_INTERVAL_MS;
-        const scoreFunction = (orderHash: string) => this._expiration[orderHash].toNumber();
-        const comparator = (lhs: string, rhs: string) => scoreFunction(lhs) - scoreFunction(rhs);
-        this._orderHashByExpirationRBTree = new RBTree(comparator);
-    }
-    public subscribe(callback: (orderHash: string) => void): void {
-        if (!_.isUndefined(this._orderExpirationCheckingIntervalIdIfExists)) {
-            throw new Error(ZeroExError.SubscriptionAlreadyPresent);
-        }
-        this._orderExpirationCheckingIntervalIdIfExists = intervalUtils.setInterval(
-            this._pruneExpiredOrders.bind(this, callback),
-            this._orderExpirationCheckingIntervalMs,
-            _.noop, // _pruneExpiredOrders never throws
-        );
-    }
-    public unsubscribe(): void {
-        if (_.isUndefined(this._orderExpirationCheckingIntervalIdIfExists)) {
-            throw new Error(ZeroExError.SubscriptionNotFound);
-        }
-        intervalUtils.clearInterval(this._orderExpirationCheckingIntervalIdIfExists);
-        delete this._orderExpirationCheckingIntervalIdIfExists;
-    }
-    public addOrder(orderHash: string, expirationUnixTimestampMs: BigNumber): void {
-        this._expiration[orderHash] = expirationUnixTimestampMs;
-        this._orderHashByExpirationRBTree.insert(orderHash);
-    }
-    public removeOrder(orderHash: string): void {
-        this._orderHashByExpirationRBTree.remove(orderHash);
-        delete this._expiration[orderHash];
-    }
-    private _pruneExpiredOrders(callback: (orderHash: string) => void): void {
-        const currentUnixTimestampMs = utils.getCurrentUnixTimestampMs();
-        while (true) {
-            const hasTrakedOrders = this._orderHashByExpirationRBTree.size === 0;
-            if (hasTrakedOrders) {
-                break;
-            }
-            const nextOrderHashToExpire = this._orderHashByExpirationRBTree.min();
-            const hasNoExpiredOrders = this._expiration[nextOrderHashToExpire].greaterThan(
-                currentUnixTimestampMs.plus(this._expirationMarginMs),
-            );
-            const isSubscriptionActive = _.isUndefined(this._orderExpirationCheckingIntervalIdIfExists);
-            if (hasNoExpiredOrders || isSubscriptionActive) {
-                break;
-            }
-            const orderHash = this._orderHashByExpirationRBTree.min();
-            this._orderHashByExpirationRBTree.remove(orderHash);
-            delete this._expiration[orderHash];
-            callback(orderHash);
-        }
-    }
+	private _orderHashByExpirationRBTree: RBTree<string>;
+	private _expiration: { [orderHash: string]: BigNumber } = {};
+	private _orderExpirationCheckingIntervalMs: number;
+	private _expirationMarginMs: number;
+	private _orderExpirationCheckingIntervalIdIfExists?: NodeJS.Timer;
+	constructor(expirationMarginIfExistsMs?: number, orderExpirationCheckingIntervalIfExistsMs?: number) {
+		this._expirationMarginMs = expirationMarginIfExistsMs || DEFAULT_EXPIRATION_MARGIN_MS;
+		this._orderExpirationCheckingIntervalMs =
+			expirationMarginIfExistsMs || DEFAULT_ORDER_EXPIRATION_CHECKING_INTERVAL_MS;
+		const scoreFunction = (orderHash: string) => this._expiration[orderHash].toNumber();
+		const comparator = (lhs: string, rhs: string) => scoreFunction(lhs) - scoreFunction(rhs);
+		this._orderHashByExpirationRBTree = new RBTree(comparator);
+	}
+	public subscribe(callback: (orderHash: string) => void): void {
+		if (!_.isUndefined(this._orderExpirationCheckingIntervalIdIfExists)) {
+			throw new Error(ZeroExError.SubscriptionAlreadyPresent);
+		}
+		this._orderExpirationCheckingIntervalIdIfExists = intervalUtils.setInterval(
+			this._pruneExpiredOrders.bind(this, callback),
+			this._orderExpirationCheckingIntervalMs,
+			_.noop, // _pruneExpiredOrders never throws
+		);
+	}
+	public unsubscribe(): void {
+		if (_.isUndefined(this._orderExpirationCheckingIntervalIdIfExists)) {
+			throw new Error(ZeroExError.SubscriptionNotFound);
+		}
+		intervalUtils.clearInterval(this._orderExpirationCheckingIntervalIdIfExists);
+		delete this._orderExpirationCheckingIntervalIdIfExists;
+	}
+	public addOrder(orderHash: string, expirationUnixTimestampMs: BigNumber): void {
+		this._expiration[orderHash] = expirationUnixTimestampMs;
+		this._orderHashByExpirationRBTree.insert(orderHash);
+	}
+	public removeOrder(orderHash: string): void {
+		this._orderHashByExpirationRBTree.remove(orderHash);
+		delete this._expiration[orderHash];
+	}
+	private _pruneExpiredOrders(callback: (orderHash: string) => void): void {
+		const currentUnixTimestampMs = utils.getCurrentUnixTimestampMs();
+		while (true) {
+			const hasTrakedOrders = this._orderHashByExpirationRBTree.size === 0;
+			if (hasTrakedOrders) {
+				break;
+			}
+			const nextOrderHashToExpire = this._orderHashByExpirationRBTree.min();
+			const hasNoExpiredOrders = this._expiration[nextOrderHashToExpire].greaterThan(
+				currentUnixTimestampMs.plus(this._expirationMarginMs),
+			);
+			const isSubscriptionActive = _.isUndefined(this._orderExpirationCheckingIntervalIdIfExists);
+			if (hasNoExpiredOrders || isSubscriptionActive) {
+				break;
+			}
+			const orderHash = this._orderHashByExpirationRBTree.min();
+			this._orderHashByExpirationRBTree.remove(orderHash);
+			delete this._expiration[orderHash];
+			callback(orderHash);
+		}
+	}
 }