Last active
November 12, 2019 14:31
-
-
Save Tvaroh/bf2430c111ca904af7bc9a74dd6d5730 to your computer and use it in GitHub Desktop.
Monix Task's Async instance for Korolev
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import korolev.Async | |
import korolev.Async.Promise | |
import monix.eval.Task | |
import monix.execution.Scheduler | |
import scala.util.{Failure, Success, Try} | |
class TaskAsync(implicit scheduler: Scheduler) extends Async[Task] { | |
override val unit: Task[Unit] = Task.unit | |
override def pure[A](value: A): Task[A] = Task.now(value) | |
override def delay[A](value: => A): Task[A] = Task.eval(value) | |
override def fork[A](value: => A): Task[A] = Task(value) | |
override def fromTry[A](value: => Try[A]): Task[A] = Task.fromTry(value) | |
override def promise[A]: korolev.Async.Promise[Task, A] = { | |
val promise = scala.concurrent.Promise[A]() | |
new Promise[Task, A] { | |
val async: Task[A] = Task.fromFuture(promise.future) | |
def complete(`try`: Try[A]): Unit = { | |
promise.complete(`try`) | |
() | |
} | |
def completeAsync(async: Task[A]): Unit = { | |
promise.completeWith(async.runToFuture) | |
() | |
} | |
} | |
} | |
override def flatMap[A, B](m: Task[A])(f: A => Task[B]): Task[B] = m.flatMap(f) | |
override def map[A, B](m: Task[A])(f: A => B): Task[B] = m.map(f) | |
override def recover[A](m: Task[A])(f: PartialFunction[Throwable, A]): Task[A] = m.onErrorRecover(f) | |
override def sequence[A](in: List[Task[A]]): Task[List[A]] = | |
Task.sequence(in) | |
override def run[A, U](m: Task[A])(f: Try[A] => U): Unit = { | |
m.runAsync { r => { f(r.fold(Failure(_), Success(_))); () } } | |
() | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment