pekko
pekko copied to clipboard
Switch code that uses Reactive Streams to favour the Java 9 Flow API
- We have PublisherSource and SubscriberSource but these are based on the org.reactivestreams API. We have other methods and classes to support the Java 9 equivalents but these involve delegating to the org.reactivestreams based classes.
- It seems like for performance reasons we should using code that uses the Java 9 classes directly instead of doing conversions.
- It's possible that the code is this way as it was easier when we had to support Java 8 to minimise the code that uses the Java 9 APIs
I think we should delay this , until reactor-core is using Flow directly, we should move this after Reactor-Core and RxJava