fix(rstream): Fix unbound this in method call expression

thi-ng · Aug 27, 2018 · 34a97b4 · 34a97b4
1 parent 917d81d
commit 34a97b4
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/packages/rstream/src/subs/resolve.ts b/packages/rstream/src/subs/resolve.ts
@@ -57,7 +57,14 @@ export class Resolver<T> extends Subscription<Promise<T>, T> {
                     DEBUG && console.log(`resolved value in ${State[this.state]} state (${x})`);
                 }
             },
-            (e) => (this.fail || this.error)(e)
+            (e) => {
+                if (this.fail) {
+                    this.fail(e);
+                }
+                else {
+                    this.error(e);
+                }
+            }
         );
     }