Ben Ng

I expected the collectList() operator always emit the error. Thus, the onErrorResume() call always return empty flux.   I don’t expect the last map flatMap(evt -> ...) block will be triggered...

Thanks for your updated. For 2. Would you please tell me why Flux.zip operator terminates once mono1 completed? As in the code, mono1 should emit a data Optional.empty(). Should Flux.zip...