-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
None
MonoRxInvoker was originally created by following SingleRxInvoker (RxJava2); however, it turns out that it is doing eager processing. In Reactor, unless there is a specific reason, the pipeline should be lazy.
For instance, the following code starts making the http call before a subscription starts:
final Mono<Response> mono = client.target(generateURL("/hello")).request().rx(MonoRxInvoker.class).get();
It should instead wait for the subscription to start the http call:
mono.subscribe();