Java 9 introduces a reactive streams-based API in the class java.util.concurrent.Flow, which defines three relevant static interfaces:

• Publisher
• Subscriber
• Subscription

We should provide a new API based on these interfaces, similar to our rxjava and reactivestreams drivers. But since these are core APIs in the JDK we can offer these in a module of the main driver (e.g driver-flow or driver-async-flow).