Merge pull request #3385 from fredfp/fix-3384

armanbilge · web-flow · commit 36fc9b255835 · 2024-02-07T19:41:57.000-08:00
diff --git a/reactive-streams/src/main/scala/fs2/interop/reactivestreams/StreamSubscription.scala b/reactive-streams/src/main/scala/fs2/interop/reactivestreams/StreamSubscription.scala
@@ -87,6 +87,7 @@ private[reactivestreams] final class StreamSubscription[F[_], A] private (
         case Outcome.Canceled()  => cancelMe
       }
       .void
+      .voidError // errors handled above and passed to subscriber
   }
 
   // According to the spec, it's acceptable for a concurrent cancel to not

Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,7 @@ private[reactivestreams] final class StreamSubscription[F[_], A] private (`
`87`	`87`	`case Outcome.Canceled() => cancelMe`
`88`	`88`	`}`
`89`	`89`	`.void`
	`90`	`+ .voidError // errors handled above and passed to subscriber`
`90`	`91`	`}`
`91`	`92`
`92`	`93`	`// According to the spec, it's acceptable for a concurrent cancel to not`