From 866a220a981359502d88c993b664a14eb3718f76 Mon Sep 17 00:00:00 2001 From: Jianghao Lu Date: Fri, 26 Aug 2016 18:48:24 -0700 Subject: [PATCH] Adapt fluent impls to use native observables --- .../java/com/microsoft/rest/ServiceCall.java | 25 ------------------- 1 file changed, 25 deletions(-) diff --git a/client-runtime/src/main/java/com/microsoft/rest/ServiceCall.java b/client-runtime/src/main/java/com/microsoft/rest/ServiceCall.java index f04232e75cbc8..39e6c05d08b95 100644 --- a/client-runtime/src/main/java/com/microsoft/rest/ServiceCall.java +++ b/client-runtime/src/main/java/com/microsoft/rest/ServiceCall.java @@ -131,31 +131,6 @@ protected void setSubscription(Subscription subscription) { this.subscription = subscription; } - /** - * Get an RxJava Observable object for the response. - * - * @return the Observable - */ - public Observable observable() { - return Observable.from(this) - .map(new Func1, T>() { - @Override - public T call(ServiceResponse tServiceResponse) { - return tServiceResponse.getBody(); - } - }); - } - - /** - * Get an RxJava Observable object for the response bound on a scheduler. - * - * @param scheduler the scheduler to bind to - * @return the Observable - */ - public Observable observable(Scheduler scheduler) { - return observable().subscribeOn(scheduler); - } - /** * Invoke this method to report completed, allowing * {@link AbstractFuture#get()} to be unblocked.