diff --git a/worker/wallet.js b/worker/wallet.js
index ac749e48..33f6d1a7 100644
--- a/worker/wallet.js
+++ b/worker/wallet.js
@@ -34,7 +34,10 @@ function subscribeForever (subscribe) {
         }
         if (sub.then) {
           // sub is promise
-          sub.then(sub => sub.on('error', reject))
+          sub.then(resolved => {
+            sub = resolved
+            sub.on('error', reject)
+          })
         } else {
           sub.on('error', reject)
         }