@Override
        public void onFailure(Exception exception) {
          source.onError(exception);
        }
Wrapper for {@link RestClient} which uses RxJava types
criteria/elasticsearch/src/org/immutables/criteria/elasticsearch/RxJavaTransport.java