fix(rstream): minor fix StreamSync.addAll()

thi-ng · Apr 24, 2018 · cc286e1 · cc286e1
1 parent fa36f98
commit cc286e1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/rstream/src/stream-sync.ts b/packages/rstream/src/stream-sync.ts
@@ -144,7 +144,7 @@ export class StreamSync<A, B> extends Subscription<A, B> {
             for (let s of <ISubscribable<A>[]>src) {
                 this.sourceIDs.add(s.id);
             }
-            for (let s of src) {
+            for (let s of <ISubscribable<A>[]>src) {
                 this.add(s);
             }
         }