RxJava3ConverterRegistrar is updated to wrap the source Publisher in a context-aware publisher that propagates any available context when converting to an RxJava type.
This solves the general case where the internal Micronaut implementation is using Reactor types and the Reactor context API, but then the type is converted to an RxJava type such as Flowable as required by the user's code. For example, this happens when applying the declarative HttpClient to a user's interface or abstract class that uses RxJava types.
RxJava3ConverterRegistrar
is updated to wrap the sourcePublisher
in a context-aware publisher that propagates any available context when converting to an RxJava type.This solves the general case where the internal Micronaut implementation is using Reactor types and the Reactor context API, but then the type is converted to an RxJava type such as
Flowable
as required by the user's code. For example, this happens when applying the declarativeHttpClient
to a user's interface or abstract class that uses RxJava types.This resolves #306.