[
https://issues.apache.org/jira/browse/CXF-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245606#comment-16245606
]
John D. Ament commented on CXF-7535:
------------------------------------
Hi Sergey,
I don't believe we can actually de-dupe them. AbstractSubscriber uses the
reactor specific subscriber object, whereas AbstractAsyncSubscriber is designed
for the RxJava class. So while the implementations of both are very similar,
they each rely on the implementation specific subscription. DeafultSubscriber
is from RxJava 2, and has no direct equivalent in Reactor.
As for why there are subtle differences. In Project Reactor, you have a mono
which is always 0/1. It doesn't make sense to send this over the wire as an
array type. Likewise, a consumer should only ever try to read this as a single
entry. Hence I had to make a small modification to support no
prefix/suffix/separator.
> Support for Project Reactor as rx()
> -----------------------------------
>
> Key: CXF-7535
> URL: https://issues.apache.org/jira/browse/CXF-7535
> Project: CXF
> Issue Type: New Feature
> Components: JAX-RS
> Affects Versions: 3.2.0
> Reporter: John D. Ament
> Assignee: John D. Ament
> Fix For: 3.2.2
>
>
> It would be good if Project Reactor was supported as an rx() type in CXF.
> https://github.com/apache/cxf/tree/master/rt/rs/extensions/rx - only shows rx
> java and rx java 2. project reactor/reactor core seem like the v3's of this
> api stack.
> https://projectreactor.io/
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
