Don't re-throw in pipeTo when receive from upstream fails

softwaremill · Oct 30, 2023 · d17a43e · d17a43e
1 parent fb8bad7
commit d17a43e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/ox/channels/SourceOps.scala b/core/src/main/scala/ox/channels/SourceOps.scala
@@ -396,7 +396,7 @@ trait SourceOps[+T] { this: Source[T] =>
     repeatWhile {
       receive() match
         case ChannelClosed.Done     => sink.done(); false
-        case e: ChannelClosed.Error => sink.error(e.reason); throw e.toThrowable
+        case e: ChannelClosed.Error => sink.error(e.reason); false
         case t: T @unchecked        => sink.send(t).orThrow; true
     }