pekko icon indicating copy to clipboard operation
pekko copied to clipboard

Switch code that uses Reactive Streams to favour the Java 9 Flow API

Open pjfanning opened this issue 2 months ago • 1 comments

  • 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

pjfanning avatar Nov 08 '25 21:11 pjfanning

I think we should delay this , until reactor-core is using Flow directly, we should move this after Reactor-Core and RxJava

He-Pin avatar Nov 10 '25 03:11 He-Pin