fix incorrect stream type for flatmap

clear · Apr 16, 2024 · 56147df · 56147df
1 parent 70f3620
commit 56147df
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/.changeset/lemon-planets-confess.md b/.changeset/lemon-planets-confess.md
@@ -0,0 +1,5 @@
+---
+"windpipe": patch
+---
+
+fix incorrect stream type for `flatTap`
diff --git a/src/stream/higher-order.ts b/src/stream/higher-order.ts
@@ -101,7 +101,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
      *
      * @group Higher Order
      */
-    flatTap(cb: (value: T) => MaybePromise<MaybeAtom<Stream<T, E>, E>>): Stream<T, E> {
+    flatTap(cb: (value: T) => MaybePromise<MaybeAtom<Stream<unknown, unknown>, E>>): Stream<T, E> {
         const trace = this.trace("flatTap");
 
         return this.consume(async function* (it) {