Home

Welcome to the reactor-scala-extensions!

This project is a scala extensions for flux and mono in reactor project.

What has been done:

1. Wrapper for Mono (v0.1.x) based on reactor-core 3.0.4.RELEASE
2. Support for ExecutionContext based Scheduler
3. Wrapper for Flux (v0.2.2) based on reactor-core 3.0.5.RELEASE
4. Wrapper for ConnectableFlux (v0.2.3) based on reactor-core 3.0.6.RELEASE

The plan was:

1. Wrapper for Reactor-Core-Test
2. Wrapper for FluxProcessor

Releases

Wrapper Release	Reactor Release
v0.1.9	3.0.4.RELEASE
v0.2.2	3.0.5.RELEASE
v0.2.3	3.0.6.RELEASE

Contribution

Contribution is always welcomed. Just fork this repo, amend, commit changes to your repo and raise pull request. Also every changes should be covered by test.