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

    }