From 3015ba3818b8547d05f3629b8ec7cf02063944c8 Mon Sep 17 00:00:00 2001
From: Naeim Taheri <nima.trueway@gmail.com>
Date: Tue, 20 Aug 2024 12:01:51 -0700
Subject: [PATCH] fix: correct type name and add a warning

---
 core/src/main/scala/ox/channels/SourceOps.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/core/src/main/scala/ox/channels/SourceOps.scala b/core/src/main/scala/ox/channels/SourceOps.scala
index 87e2395f..7ee1b5cb 100644
--- a/core/src/main/scala/ox/channels/SourceOps.scala
+++ b/core/src/main/scala/ox/channels/SourceOps.scala
@@ -413,7 +413,8 @@ trait SourceOps[+T] { outer: Source[T] =>
           case ChannelClosed.Error(e) =>
             c2.errorOrClosed(e)
             false
-          case t: Source[T] @unchecked =>
+          // TODO: we might go too deep and pull from non immediate children of the parent source
+          case t: Source[U] @unchecked =>
             pool = t :: pool
             true
           case r: U @unchecked =>