Reactive Extension (Rx) Adaptor for Netty