Skip to content

Instantly share code, notes, and snippets.

@chrisphelps
Created December 30, 2015 06:45
Show Gist options
  • Save chrisphelps/43fb1b2bd5d958728167 to your computer and use it in GitHub Desktop.
Save chrisphelps/43fb1b2bd5d958728167 to your computer and use it in GitHub Desktop.
Conversion from guava ListenableFuture to Scala Future
implicit def toScalaFuture[T](lFuture: ListenableFuture[T]): Future[T] = {
val p = Promise[T]
Futures.addCallback(lFuture,
new FutureCallback[T] {
def onSuccess(result: T) = p.success(result)
def onFailure(t: Throwable) = p.failure(t)
})
p.future
}
@leobenkel
Copy link

what are the correct import(s) ?

@Aleksei-Poliakov
Copy link

import com.google.common.util.concurrent.{FutureCallback, Futures, ListenableFuture}

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment