refactored to leverage rx-netty-scala