Skip to content

Propagate Java thread interruption in unsafeRunSync et al. #4166

Closed
Closed
Propagate Java thread interruption in unsafeRunSync et al.#4166
Labels
🪲 buggood first issue
@armanbilge

Description

@armanbilge
armanbilge
opened on Nov 12, 2024

We want to handle it similarly to the TimeoutException

cats-effect/std/jvm/src/main/scala/cats/effect/std/DispatcherPlatform.scala

Lines 58 to 65 in 725a4cd

def unsafeRunTimed[A](fa: F[A], timeout: Duration): A = {
val (fut, cancel) = unsafeToFutureCancelable(fa)
try Await.result(fut, timeout)
catch {
case t: TimeoutException =>
cancel()
throw t
}

Metadata

Metadata

Assignees

No one assigned

    Labels

    🪲 buggood first issue

    Type

    No type

    Projects

    Typelevel Good First Issues

    Status

    Done

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions