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

Don't unsubscribe on Blockstream errors

Browse Source
This commit is contained in:
Fabio Berger
2018-07-05 22:25:47 +02:00
parent 0df36471b7
commit abb38e1bc0
2 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/order-watcher/src/order_watcher/event_watcher.ts
View File

@@ -74,7 +74,7 @@ export class EventWatcher {
this._blockAndLogStreamIntervalIfExists = intervalUtils.setAsyncExcludingInterval( this._blockAndLogStreamIntervalIfExists = intervalUtils.setAsyncExcludingInterval(
this._reconcileBlockAsync.bind(this), this._reconcileBlockAsync.bind(this),
this._pollingIntervalMs, this._pollingIntervalMs,
this._onReconcileBlockError.bind(this, callback), EventWatcher._onBlockAndLogStreamerError.bind(this, callback),
); );
let isRemoved = false; let isRemoved = false;
this._onLogAddedSubscriptionToken = this._blockAndLogStreamerIfExists.subscribeToOnLogAdded( this._onLogAddedSubscriptionToken = this._blockAndLogStreamerIfExists.subscribeToOnLogAdded(
@@ -85,10 +85,6 @@ export class EventWatcher {
this._onLogStateChangedAsync.bind(this, callback, isRemoved), this._onLogStateChangedAsync.bind(this, callback, isRemoved),
); );
} }
private _onReconcileBlockError(callback: EventWatcherCallback, err: Error): void {
this.unsubscribe();
callback(err);
}
private async _onLogStateChangedAsync( private async _onLogStateChangedAsync(
callback: EventWatcherCallback, callback: EventWatcherCallback,
isRemoved: boolean, isRemoved: boolean,

1
packages/order-watcher/src/order_watcher/order_watcher.ts
View File

@@ -233,7 +233,6 @@ export class OrderWatcher {
if (!_.isNull(err)) { if (!_.isNull(err)) {
if (!_.isUndefined(this._callbackIfExists)) { if (!_.isUndefined(this._callbackIfExists)) {
this._callbackIfExists(err); this._callbackIfExists(err);
this.unsubscribe();
} }
return; return;
} }