fix: correct type name and add a warning

softwaremill · Aug 20, 2024 · 3015ba3 · 3015ba3
1 parent 52bf1ae
commit 3015ba3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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 =>