Convert an RX Observable to a Scala Promise

observabletofuture.java

 /**
     * Converts an instance of <code>Observable<T></code> into
     * an instance of <code>F.Promise<T></code>
     * 
     * @return A <code>Promise<T></code> containing the value
     * emitted by the observable
     */
    public static <T> Function<Observable<T>, F.Promise<T>> observableToFuture()
    {
          return obs ->  {
	       scala.concurrent.Promise<T> scalaPromise = scala.concurrent.Promise$.MODULE$.<T>apply();
	       obs.subscribe(
	           result -> scalaPromise.success(result),
	           throwable -> scalaPromise.failure(throwable)
	       );
	       return F.Promise.wrap(scalaPromise.future());
	    };
        
    }

We used this to convert method calls that return an Rx Observable into Scala Future/Promises