davidhoyt

import scala.util._
import scala.concurrent._
import java.util.concurrent.{Callable, FutureTask}

object Utils {
  def toJavaFuture[TScalaType, TJavaType](f: Future[TScalaType])(map: (TScalaType => TJavaType))(implicit executor: ExecutionContext): java.util.concurrent.Future[TJavaType] = {
    val applied = f.map(map)

    val task = new FutureTask[TJavaType](new Callable[TJavaType] {
      def call(): TJavaType = applied.value.get match {