Rx Observable wrapper around a NIO event loop