Advertisement
Guest User

Untitled

a guest
Feb 21st, 2019
70
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.37 KB | None | 0 0
  1. import scala.compat.java8.FutureConverters
  2. import java.util.concurrent.{CompletableFuture, Future => JFuture}
  3. import java.util.function.Supplier
  4.  
  5. def lift[F[_]: LiftIO: Sync, A](jf: JFuture[A]): F[A] =
  6. Sync[F].delay(LiftIO[F].liftIO(IO.fromFuture(IO{
  7. FutureConverters.toScala[A](CompletableFuture.supplyAsync(() => jf.get))
  8. })))
  9. .flatten
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement