Adapt ForkJoin to reactor.rx