Skip to content

Commit

Permalink
Improve Scope#interruptWhen error
Browse files Browse the repository at this point in the history
  • Loading branch information
rossabaker committed Sep 25, 2021
1 parent e59977f commit fd2d836
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion core/shared/src/main/scala/fs2/internal/Scope.scala
Original file line number Diff line number Diff line change
Expand Up @@ -397,7 +397,7 @@ private[fs2] final class Scope[F[_]] private (
interruptible match {
case None =>
F.raiseError(
new IllegalStateException("Scope#interrupt called for Scope that cannot be interrupted")
new IllegalStateException("Scope#interruptWhen called for Scope that cannot be interrupted. This can happen when a Stream uses Concurrent operations but is compiled with only a Sync constraint.")
)
case Some(iCtx) =>
val outcome: F[InterruptionOutcome] = haltWhen.map(
Expand Down

0 comments on commit fd2d836

Please sign in to comment.