refactor(rstream): update type-only imports

thi-ng · Dec 7, 2020 · cdf5d62 · cdf5d62
1 parent 6407f7d
commit cdf5d62
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 9 deletions.
diff --git a/packages/rstream/src/api.ts b/packages/rstream/src/api.ts
@@ -1,7 +1,7 @@
 import { Fn, Fn0, IDeref, IID, ILogger, NULL_LOGGER } from "@thi.ng/api";
 import type { Transducer } from "@thi.ng/transducers";
-import { Stream } from "./stream";
-import { Subscription } from "./subscription";
+import type { Stream } from "./stream";
+import type { Subscription } from "./subscription";
 
 export enum State {
     IDLE,

diff --git a/packages/rstream/src/forkjoin.ts b/packages/rstream/src/forkjoin.ts
@@ -10,7 +10,7 @@ import {
 import type { CommonOpts, ISubscribable, ITransformable } from "./api";
 import { sync } from "./stream-sync";
 import { tunnel } from "./subs/tunnel";
-import { Subscription } from "./subscription";
+import type { Subscription } from "./subscription";
 
 export interface ForkJoinOpts<IN, MSG, RES, OUT> extends Partial<CommonOpts> {
     /**

diff --git a/packages/rstream/src/from/promises.ts b/packages/rstream/src/from/promises.ts
@@ -1,6 +1,6 @@
 import { mapcat } from "@thi.ng/transducers";
 import type { CommonOpts } from "../api";
-import { Subscription } from "../subscription";
+import type { Subscription } from "../subscription";
 import { optsWithID } from "../utils/idgen";
 import { fromPromise } from "./promise";
 

diff --git a/packages/rstream/src/subs/sidechain-partition.ts b/packages/rstream/src/subs/sidechain-partition.ts
@@ -1,6 +1,6 @@
 import type { Predicate } from "@thi.ng/api";
 import { CommonOpts, ISubscribable, State } from "../api";
-import { Subscription } from "../subscription";
+import type { Subscription } from "../subscription";
 import { optsWithID } from "../utils/idgen";
 import { ASidechain } from "./asidechain";
 

diff --git a/packages/rstream/src/subs/sidechain-toggle.ts b/packages/rstream/src/subs/sidechain-toggle.ts
@@ -1,6 +1,6 @@
 import type { Predicate } from "@thi.ng/api";
 import { CommonOpts, ISubscribable, State } from "../api";
-import { Subscription } from "../subscription";
+import type { Subscription } from "../subscription";
 import { optsWithID } from "../utils/idgen";
 import { ASidechain } from "./asidechain";
 

diff --git a/packages/rstream/src/subs/transduce.ts b/packages/rstream/src/subs/transduce.ts
@@ -1,6 +1,6 @@
 import type { Reducer, Transducer } from "@thi.ng/transducers";
 import { isReduced, Reduced } from "@thi.ng/transducers";
-import { Subscription } from "../subscription";
+import type { Subscription } from "../subscription";
 
 /**
  * Returns a promise which subscribes to given input and transforms

diff --git a/packages/rstream/src/trigger.ts b/packages/rstream/src/trigger.ts
@@ -1,6 +1,6 @@
-import { CommonOpts } from "./api";
+import type { CommonOpts } from "./api";
 import { fromIterableSync } from "./from/iterable";
-import { Stream } from "./stream";
+import type { Stream } from "./stream";
 import { optsWithID } from "./utils/idgen";
 
 /**