Medium-Nima-Reactive-Parallel

reactive.java

// create a dummy stream from numbers 0 to count
Multi.range(0, count)
  // for each number, call the task on a different thread
  .flatMap(i -> Single.create(CompletableFuture.supplyAsync(() -> 
        client().get().request(String.class), EXECUTOR))
  // flat map from Single<Single<String>> to Single<String>
  .flatMap(Function.identity()))
  .collectList()
  .map(it -> "Combined results: " + it)
  .onError(res::send)
  .forSingle(res::send);