@Test
public void create() throws ExecutionException, InterruptedException {

    Predicate<Integer> even = i -> i % 2 == 0;
    Flowable<Integer> flowable = Flowable.fromArray(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
            .subscribeOn(Schedulers.computation());
    List<Integer> list = ReactiveStreams.fromPublisher(flowable).filter(even).toList().run()
            .toCompletableFuture().get();
    assertThat(list).hasSize(5).containsExactly(2, 4, 6, 8, 10);
}