aboutsummaryrefslogtreecommitdiffstats
path: root/src/order_watcher/order_state_watcher.ts
diff options
context:
space:
mode:
authorFabio Berger <me@fabioberger.com>2017-11-10 06:48:05 +0800
committerFabio Berger <me@fabioberger.com>2017-11-10 06:48:05 +0800
commitb0491b0ee28e6d9fd7e3a5647284c99bd79d4930 (patch)
tree263a8e5712fea72f78e0a571987c63b431d308b3 /src/order_watcher/order_state_watcher.ts
parent0e69356ca9dae26a2940a77d14aca79d0ff36831 (diff)
downloaddexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar.gz
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar.bz2
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar.lz
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar.xz
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.tar.zst
dexon-sol-tools-b0491b0ee28e6d9fd7e3a5647284c99bd79d4930.zip
Rename _callbackAsync to _callbackIfExistsAsync for clarity
Diffstat (limited to 'src/order_watcher/order_state_watcher.ts')
-rw-r--r--src/order_watcher/order_state_watcher.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/order_watcher/order_state_watcher.ts b/src/order_watcher/order_state_watcher.ts
index 88f6aae69..1c5898c28 100644
--- a/src/order_watcher/order_state_watcher.ts
+++ b/src/order_watcher/order_state_watcher.ts
@@ -36,7 +36,7 @@ export class OrderStateWatcher {
private _orders: OrderByOrderHash;
private _dependentOrderHashes: DependentOrderHashes;
private _web3Wrapper: Web3Wrapper;
- private _callbackAsync?: OnOrderStateChangeCallback;
+ private _callbackIfExistsAsync?: OnOrderStateChangeCallback;
private _eventWatcher: EventWatcher;
private _abiDecoder: AbiDecoder;
private _orderStateUtils: OrderStateUtils;
@@ -89,10 +89,10 @@ export class OrderStateWatcher {
*/
public subscribe(callback: OnOrderStateChangeCallback, numConfirmations: number): void {
assert.isFunction('callback', callback);
- if (!_.isUndefined(this._callbackAsync)) {
+ if (!_.isUndefined(this._callbackIfExistsAsync)) {
throw new Error(ZeroExError.SubscriptionAlreadyPresent);
}
- this._callbackAsync = callback;
+ this._callbackIfExistsAsync = callback;
this._eventWatcher.subscribe(this._onEventWatcherCallbackAsync.bind(this), numConfirmations);
}
/**
@@ -100,7 +100,7 @@ export class OrderStateWatcher {
* @param signedOrder The order you wish to stop watching.
*/
public unsubscribe(): void {
- delete this._callbackAsync;
+ delete this._callbackIfExistsAsync;
this._eventWatcher.unsubscribe();
}
private async _onEventWatcherCallbackAsync(log: LogEvent): Promise<void> {
@@ -158,8 +158,8 @@ export class OrderStateWatcher {
for (const orderHash of orderHashes) {
const signedOrder = this._orders[orderHash] as SignedOrder;
const orderState = await this._orderStateUtils.getOrderStateAsync(signedOrder, methodOpts);
- if (!_.isUndefined(this._callbackAsync)) {
- await this._callbackAsync(orderState);
+ if (!_.isUndefined(this._callbackIfExistsAsync)) {
+ await this._callbackIfExistsAsync(orderState);
} else {
break; // Unsubscribe was called
}