crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add defaults

Browse Source
This commit is contained in:
Leonid Logvinov 2017-11-20 13:02:24 -06:00
parent 35668fe225
commit a613c3b7e7
No known key found for this signature in database
GPG Key ID: 0DD294BFDE8C95D4
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/0x.js/src/order_watcher/event_watcher.ts
View File

@ -12,7 +12,7 @@ import {intervalUtils} from '../utils/interval_utils';
import {assert} from '../utils/assert'; import {assert} from '../utils/assert';
import {utils} from '../utils/utils'; import {utils} from '../utils/utils';
const DEFAULT_EVENT_POLLING_INTERVAL = 200; const DEFAULT_EVENT_POLLING_INTERVAL_MS = 200;
enum LogEventState { enum LogEventState {
Removed, Removed,
@ -28,11 +28,11 @@ export class EventWatcher {
private _pollingIntervalMs: number; private _pollingIntervalMs: number;
private _intervalIdIfExists?: NodeJS.Timer; private _intervalIdIfExists?: NodeJS.Timer;
private _lastEvents: Web3.LogEntry[] = []; private _lastEvents: Web3.LogEntry[] = [];
constructor(web3Wrapper: Web3Wrapper, pollingIntervalMs: undefined|number) { constructor(web3Wrapper: Web3Wrapper, pollingIntervalIfExistsMs: undefined|number) {
this._web3Wrapper = web3Wrapper; this._web3Wrapper = web3Wrapper;
this._pollingIntervalMs = _.isUndefined(pollingIntervalMs) ? this._pollingIntervalMs = _.isUndefined(pollingIntervalIfExistsMs) ?
DEFAULT_EVENT_POLLING_INTERVAL : DEFAULT_EVENT_POLLING_INTERVAL_MS :
pollingIntervalMs; pollingIntervalIfExistsMs;
} }
public subscribe(callback: EventWatcherCallback): void { public subscribe(callback: EventWatcherCallback): void {
assert.isFunction('callback', callback); assert.isFunction('callback', callback);

4
packages/0x.js/src/order_watcher/order_state_watcher.ts
View File

@ -67,8 +67,8 @@ export class OrderStateWatcher {
) { ) {
this._abiDecoder = abiDecoder; this._abiDecoder = abiDecoder;
this._web3Wrapper = web3Wrapper; this._web3Wrapper = web3Wrapper;
const eventPollingIntervalMs = _.isUndefined(config) ? undefined : config.eventPollingIntervalMs; const pollingIntervalIfExistsMs = _.isUndefined(config) ? undefined : config.eventPollingIntervalMs;
this._eventWatcher = new EventWatcher(web3Wrapper, eventPollingIntervalMs); this._eventWatcher = new EventWatcher(web3Wrapper, pollingIntervalIfExistsMs);
this._balanceAndProxyAllowanceLazyStore = new BalanceAndProxyAllowanceLazyStore(token); this._balanceAndProxyAllowanceLazyStore = new BalanceAndProxyAllowanceLazyStore(token);
this._orderFilledCancelledLazyStore = new OrderFilledCancelledLazyStore(exchange); this._orderFilledCancelledLazyStore = new OrderFilledCancelledLazyStore(exchange);
this._orderStateUtils = new OrderStateUtils( this._orderStateUtils = new OrderStateUtils(

4
packages/0x.js/src/types.ts
View File

@ -397,8 +397,8 @@ export interface JSONRPCPayload {
} }
/* /*
* orderExpirationCheckingIntervalMs: How often to check for expired orders * orderExpirationCheckingIntervalMs: How often to check for expired orders. Default: 50
* eventPollingIntervalMs: How often to poll the Ethereum node for new events * eventPollingIntervalMs: How often to poll the Ethereum node for new events. Defaults: 200
*/ */
export interface OrderStateWatcherConfig { export interface OrderStateWatcherConfig {
orderExpirationCheckingIntervalMs?: number; orderExpirationCheckingIntervalMs?: number;