Reactive Streams
Engellemesiz geri basınç (backpressure) sunan asenkron akışlar için bir spesifikasyon; 2013–2015 arasında Netflix, Lightbend ve Pivotal çalışanlarınca geliştirildi. Dört arayüzü var: Publisher, Subscriber, Subscription, Processor.
Bütün mesele Subscription.request(n) çağrısında: tüketici ne kadarını kaldırabileceğini söyler, üretici bunu aşamaz. Bu mekanizma olmadan hızlı bir üretici, yavaş bir tüketicinin belleğini doldurur. Spesifikasyon JDK 9’a java.util.concurrent.Flow olarak alındı: arayüzler aynı, paket adı farklı. Uygulamalar: RxJava 2+, Project Reactor (Spring WebFlux), Akka Streams, Vert.x, Mutiny. Birlikte çalışabilirlik tüm satış argümanı; bir Reactor kaynağını Akka havuzuna bağlayabilirsiniz.