Skip to content

Commit

Permalink
Remove unused named pattern in mapParUnordered
Browse files Browse the repository at this point in the history
  • Loading branch information
rucek committed Oct 30, 2023
1 parent 55319a1 commit f3214bc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion core/src/main/scala/ox/channels/SourceOps.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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 =>
Expand Down
2 changes: 1 addition & 1 deletion doc/adr/0001-error-propagation-in-channels.md
Original file line number Diff line number Diff line change
Expand Up @@ -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 =>
Expand Down

0 comments on commit f3214bc

Please sign in to comment.