This work is based on https://github.com/playframework/netty-reactive-streams/