lhotari commented on issue #10: URL: https://github.com/apache/pulsar-client-reactive/issues/10#issuecomment-1293755039
I'm closing this as "wontfix". The solution for #1 is sufficient. I made a broad experiment of a full blown approach where the whole API is mirrored for a specific Reactive Streams implementation, hiding the Project Reactor types completely. This experiment is in branch https://github.com/lhotari/pulsar-client-reactive/tree/lh-rs-impl-experiment . The value of the wrapping is very minimal. All Reactive Streams libraries have interoperability with RS Publisher. Hiding this translation is just going to be more messy than using code for doing it. One possible solution to the problem is to use Project Reactor's `.as` method (`<P> P as(Function<? super Flux<T>, P> transformer)`) to convert a Flux or Mono to another type. For example, converting to RxJava3, would be as simple as `.as(Flowable::from)` or `.as(Single::from)`. Similar chaining with `.as` method could be done for Akka Streams and any other Reactive Streams implementation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
