fix(rstream): avoid Subscription ctor to workaround parceljs build issue

- use `subscription()` factory instead of `new Subscription` - solves issue w/ parcel's scope hoisting build flag
thi-ng · Jan 5, 2019 · d1e275b · d1e275b
1 parent e201ca8
commit d1e275b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/packages/rstream/src/pubsub.ts b/packages/rstream/src/pubsub.ts
@@ -3,7 +3,7 @@ import { EquivMap } from "@thi.ng/associative/equiv-map";
 import { unsupported } from "@thi.ng/errors/unsupported";
 import { Transducer } from "@thi.ng/transducers/api";
 import { DEBUG, ISubscriber } from "./api";
-import { Subscription } from "./subscription";
+import { Subscription, subscription } from "./subscription";
 import { nextID } from "./utils/idgen";
 
 export interface PubSubOpts<A, B> {
@@ -84,7 +84,7 @@ export class PubSub<A, B> extends Subscription<A, B> {
     subscribeTopic(topicID: any, sub: any, id?: string): Subscription<any, any> {
         let t = this.topics.get(topicID);
         if (!t) {
-            this.topics.set(topicID, t = new Subscription<B, B>());
+            this.topics.set(topicID, t = subscription<B, B>());
         }
         return t.subscribe(sub, id);
     }

diff --git a/packages/rstream/src/subscription.ts b/packages/rstream/src/subscription.ts
@@ -130,7 +130,7 @@ export class Subscription<A, B> implements
         if (implementsFunction(sub, "subscribe")) {
             sub.parent = this;
         } else {
-            sub = new Subscription(sub, xform, this, id);
+            sub = subscription(sub, xform, this, id);
         }
         if (this.last !== SEMAPHORE) {
             sub.next(this.last);