@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");

}