An RxNetty wrapper for Scala