Setup
To add this extension all you have to do is add the following dependency:
implementation 'com.femastudios:dataflow-mediator-reactivestreams:1.0.0'<dependency>
<groupId>com.femastudios</groupId>
<artifactId>dataflow-mediator-reactivestreams</artifactId>
<version>1.0.0</version>
</dependency>Remember also to properly configure your environment as explained as explained here.