diff --git a/core/src/main/scala/ox/channels/SourceOps.scala b/core/src/main/scala/ox/channels/SourceOps.scala index 183f664e..befda1bd 100644 --- a/core/src/main/scala/ox/channels/SourceOps.scala +++ b/core/src/main/scala/ox/channels/SourceOps.scala @@ -181,7 +181,7 @@ trait SourceOps[+T] { this: Source[T] => s.acquire() receive() match case ChannelClosed.Done => false - case e @ ChannelClosed.Error(r) => + case ChannelClosed.Error(r) => c.error(r) false case t: T @unchecked => diff --git a/doc/adr/0001-error-propagation-in-channels.md b/doc/adr/0001-error-propagation-in-channels.md index 264e648b..274d78d8 100644 --- a/doc/adr/0001-error-propagation-in-channels.md +++ b/doc/adr/0001-error-propagation-in-channels.md @@ -41,7 +41,7 @@ def mapParUnordered[U](parallelism: Int)(f: T => U)(using Ox, StageCapacity): So s.acquire() receive() match case ChannelClosed.Done => false - case e @ ChannelClosed.Error(r) => // (2) + case ChannelClosed.Error(r) => // (2) c.error(r) false case t: T @unchecked =>