Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import scala.compat.java8.FutureConverters
- import java.util.concurrent.{CompletableFuture, Future => JFuture}
- import java.util.function.Supplier
- def lift[F[_]: LiftIO: Sync, A](jf: JFuture[A]): F[A] =
- Sync[F].delay(LiftIO[F].liftIO(IO.fromFuture(IO{
- FutureConverters.toScala[A](CompletableFuture.supplyAsync(() => jf.get))
- })))
- .flatten
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement