feat(BaseService): Add implementation for reactive service calls with and without added detail

Author: lpatino10

src/main/java/com/ibm/cloud/sdk/core/http/ServiceCall.java

@@ -12,6 +12,7 @@
  */
 package com.ibm.cloud.sdk.core.http;
 
+import io.reactivex.Single;
 import jersey.repackaged.jsr166e.CompletableFuture;
 
 /**
@@ -75,4 +76,19 @@ public interface ServiceCall<T> {
    * @return a CompletableFuture wrapper for your response
    */
   CompletableFuture<Response<T>> rxWithDetails();
+
+  /**
+   * Reactive request using the RxJava 2 library. See https://github.com/ReactiveX/RxJava.
+   *
+   * @return a Single object containing the service call to be observed/subscribed to
+   */
+  Single<T> reactiveRequest();
+
+  /**
+   * Reactive request using the RxJava 2 library. See https://github.com/ReactiveX/RxJava. In addition, the wrapped
+   * service call will contain added HTTP information.
+   *
+   * @return a Single object containing the service call to be observed/subscribed to
+   */
+  Single<Response<T>> reactiveRequestWithDetails();
 }

src/main/java/com/ibm/cloud/sdk/core/service/BaseService.java

@@ -35,6 +35,7 @@
 import com.ibm.cloud.sdk.core.service.security.IamTokenManager;
 import com.ibm.cloud.sdk.core.util.CredentialUtils;
 import com.ibm.cloud.sdk.core.util.RequestUtils;
+import io.reactivex.Single;
 import jersey.repackaged.jsr166e.CompletableFuture;
 import okhttp3.Call;
 import okhttp3.Callback;
@@ -47,6 +48,7 @@
 
 import java.io.IOException;
 import java.util.Map;
+import java.util.concurrent.Callable;
 import java.util.logging.Logger;
 import java.util.regex.Pattern;
 
@@ -586,6 +588,29 @@ public void onResponse(Call call, Response response) {
       return completableFuture;
     }
 
+    @Override
+    public Single<T> reactiveRequest() {
+      return Single.fromCallable(new Callable<T>() {
+        @Override
+        public T call() throws Exception {
+          Response response = call.execute();
+          return processServiceCall(converter, response);
+        }
+      });
+    }
+
+    @Override
+    public Single<com.ibm.cloud.sdk.core.http.Response<T>> reactiveRequestWithDetails() {
+      return Single.fromCallable(new Callable<com.ibm.cloud.sdk.core.http.Response<T>>() {
+        @Override
+        public com.ibm.cloud.sdk.core.http.Response<T> call() throws Exception {
+          Response httpResponse = call.execute();
+          T responseModel = processServiceCall(converter, httpResponse);
+          return new com.ibm.cloud.sdk.core.http.Response<>(responseModel, httpResponse);
+        }
+      });
+    }
+
     @Override
     protected void finalize() throws Throwable {
       super.finalize();