cats-effect
cats-effect copied to clipboard
typelevel
The pure asynchronous runtime for Scala
Extention to the current `Mutex` class to support one look per `key`. I extracted the `LockQueue` and `lock` implementations into their own file to allow reuse. I added a basic...
unsafeToFuture fails to raise a second InterruptedException if the exception is handled and retried
The code below catches a ExecutionException which wraps the Interrupted exception on the first iteration. On the second iteration no ExecutionException is thrown and the main thread blocks on the...
... or other `Executor`s. I've noticed this when debugging #4055. PR incoming...
`timeout*` methods are implemented in terms of a race between a desired effect and the timeout. In the case that both effects complete simultaneously, it could happen that the timeout...
The `onError` that you get from `ApplicativeError` has this signature: ``` def onError[A](fa: F[A])(pf: PartialFunction[E, F[Unit]]): F[A] ``` While the "native" one in `IO` doesn't take a `PartialFunction`: ``` def...
fixes #3646 I will open another pull request against the g8 template adding the warning.
https://github.com/typelevel/cats-effect/actions/runs/8770540919/job/24067204067#step:23:4961 ``` [error] ! backpressure on cancelation [error] cats.effect.TestTimeoutException: null (/home/runner/work/cats-effect/cats-effect/tests/js/target/scala-2.12/cats-effect-tests-test-fastopt/file:/home/runner/work/cats-effect/cats-effect/tests/shared/src/test/scala/cats/effect/Runners.scala:120) [error] {anonymous}()(/home/runner/work/cats-effect/cats-effect/tests/js/target/scala-2.12/cats-effect-tests-test-fastopt/file:/home/runner/work/cats-effect/cats-effect/tests/shared/src/test/scala/cats/effect/Runners.scala:120:30) [error] cats.effect.Runners$$Lambda$1.run(/home/runner/work/cats-effect/cats-effect/tests/js/target/scala-2.12/cats-effect-tests-test-fastopt/file:/home/runner/work/cats-effect/cats-effect/tests/shared/src/test/scala/cats/effect/Runners.scala:119:16) [error] {anonymous}()(/home/runner/work/cats-effect/cats-effect/tests/js/target/scala-2.12/cats-effect-tests-test-fastopt/https:/raw.githubusercontent.com/typelevel/cats-effect/b47fb3b38ecbeb4c954e01978a09fb8f7efe8376/core/js/src/main/scala/cats/effect/unsafe/SchedulerCompanionPlatform.scala:33:59) [error] Timeout._onTimeout(/home/runner/work/cats-effect/cats-effect/tests/js/target/scala-2.12/cats-effect-tests-test-fastopt/https:/raw.githubusercontent.com/scala-js/scala-js/v1.16.0/library/src/main/scala/scala/scalajs/js/timers/package.scala:53:32) [error] listOnTimeout(node:internal/timers:569:17) [error] processTimers(node:internal/timers:512:7) [info] Total for specification AsyncSpec [info] Finished...
The following fails fairly quickly: ```scala while (true) { val (future, cancel) = IO.never.unsafeToFutureCancelable() Await.result(cancel(), Duration.Inf) assert(future.isCompleted) } ``` I believe `future` actually has finished it's work, as the following...
I try to use FS2 from inside Unreal engine via Unreal.js plugin, which essentially is a wrapper around V8 JavaScript engine, but I get into undefined required script 'perf_hooks', and...
