From 56147df6653f748e410a20547dd4085e796ed203 Mon Sep 17 00:00:00 2001
From: Tom Anderson <tom@ando.gq>
Date: Tue, 16 Apr 2024 15:28:06 +1000
Subject: [PATCH] fix incorrect stream type for flatmap

---
 .changeset/lemon-planets-confess.md | 5 +++++
 src/stream/higher-order.ts          | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/lemon-planets-confess.md

diff --git a/.changeset/lemon-planets-confess.md b/.changeset/lemon-planets-confess.md
new file mode 100644
index 0000000..b862eed
--- /dev/null
+++ 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
index 4fd6adb..f2acdeb 100644
--- 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) {