@Test
public void fromCompletableFuture() {

    final CompletableFuture<String> cf = CompletableFuture.supplyAsync(CompletableFutureToObservableTest::supplyValue);
    //final Observable<String> observable = CompletableFutureToObservable.fromCompletableFuture(cf);
    final Observable<String> observable = CompletableFutureToObservable.fromCompletableFuture(cf);
    observable.blockingSubscribe(System.out::println);
    System.out.println("Done");
}