1 files changed, 1 insertions, 5 deletions
diff --git a/packages/order-watcher/src/order_watcher/event_watcher.ts b/packages/order-watcher/src/order_watcher/event_watcher.ts
index 9a4089384..0e27cd64b 100644
--- a/packages/order-watcher/src/order_watcher/event_watcher.ts
+++ b/packages/order-watcher/src/order_watcher/event_watcher.ts
@@ -74,7 +74,7 @@ export class EventWatcher {
         this._blockAndLogStreamIntervalIfExists = intervalUtils.setAsyncExcludingInterval(
             this._reconcileBlockAsync.bind(this),
             this._pollingIntervalMs,
-            this._onReconcileBlockError.bind(this, callback),
+            EventWatcher._onBlockAndLogStreamerError.bind(this, callback),
         );
         let isRemoved = false;
         this._onLogAddedSubscriptionToken = this._blockAndLogStreamerIfExists.subscribeToOnLogAdded(
@@ -85,10 +85,6 @@ export class EventWatcher {
             this._onLogStateChangedAsync.bind(this, callback, isRemoved),
         );
     }
-    private _onReconcileBlockError(callback: EventWatcherCallback, err: Error): void {
-        this.unsubscribe();
-        callback(err);
-    }
     private async _onLogStateChangedAsync(
         callback: EventWatcherCallback,
         isRemoved: boolean,