As reported on rxjava we should adapt the fix for reactor fusion path too https://github.com/ReactiveX/RxJava/issues/6144