Reactive Streams
Especificación para flujos asíncronos con contrapresión no bloqueante. Desarrollada entre 2013 y 2015 por gente de Netflix, Lightbend y Pivotal. Cuatro interfaces: Publisher, Subscriber, Subscription, Processor.
Todo gira en torno a Subscription.request(n): el consumidor indica cuánto es capaz de recibir, y el productor no puede enviar más. Sin ese mecanismo, un productor rápido llena la memoria de un consumidor lento. La especificación se incorporó al JDK 9 como java.util.concurrent.Flow —interfaces idénticas, distinto nombre de paquete—. Implementaciones: RxJava 2+, Project Reactor (Spring WebFlux), Akka Streams, Vert.x, Mutiny. La interoperabilidad es la gracia del asunto —se puede conectar una fuente de Reactor con un sumidero de Akka—.