executeAsync

Co-authored-by: Flavio Brasil <[email protected]>
getkyo · Nov 19, 2024 · 949b664 · 949b664
1 parent 1ff27e8
commit 949b664
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kyo-monix/shared/src/main/scala/kyo/Monix.scala b/kyo-monix/shared/src/main/scala/kyo/Monix.scala
@@ -8,7 +8,7 @@ object Monix:
     def get[A: Flat](task: Task[A])(using monix.execution.Scheduler, Frame): A < (Abort[Throwable] & Async) =
         IO.Unsafe {
             val p = Promise.Unsafe.init[Throwable, A]()
-            val cancelable = task.runAsync { (e: Either[Throwable, A]) =>
+            val cancelable = task.executeAsync.runAsync { (e: Either[Throwable, A]) =>
                 p.completeDiscard(Result.fromEither(e))
             }
             p.onInterrupt(_ => discard(cancelable.cancel()))