diff --git a/packages/rstream/src/api.ts b/packages/rstream/src/api.ts
index 6b935ef846..9cc18cee1a 100644
--- 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
index 4dae1ab109..b72ee88491 100644
--- 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
index 71789740a8..543cc0b97c 100644
--- 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
index ed5f95289f..0777b58f36 100644
--- 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
index 05f034bff9..0954670f74 100644
--- 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
index de491e1da1..7de06a31bc 100644
--- 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
index 9dcb8cb67b..36df61a90c 100644
--- 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";
 
 /**