Fix socket timeout and parallel creation

jianghaolu · Aug 29, 2016 · 7fb2d38 · 7fb2d38
1 parent 2c7a100
commit 7fb2d38
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/azure-client-runtime/src/main/java/com/microsoft/azure/RestClient.java b/azure-client-runtime/src/main/java/com/microsoft/azure/RestClient.java
@@ -169,6 +169,7 @@ public Builder(OkHttpClient.Builder httpClientBuilder, Retrofit.Builder retrofit
             // Set up OkHttp client
             this.httpClientBuilder = httpClientBuilder
                     .cookieJar(new JavaNetCookieJar(cookieManager))
+                    .readTimeout(30, TimeUnit.SECONDS)
                     .addInterceptor(userAgentInterceptor);
             this.retrofitBuilder = retrofitBuilder;
             this.buildable = new Buildable();

diff --git a/azure-client-runtime/src/main/java/com/microsoft/azure/TaskGroupBase.java b/azure-client-runtime/src/main/java/com/microsoft/azure/TaskGroupBase.java
@@ -70,7 +70,7 @@ public void execute() throws Exception {
 
     @Override
     public Observable<T> executeAsync() {
-        return executeReadyTasksAsync();
+        return executeReadyTasksAsync().last();
     }
 
     @Override
@@ -101,6 +101,6 @@ public Observable<T> call(T t) {
                     }));
             nextNode = dag.getNext();
         }
-        return Observable.merge(observables).last();
+        return Observable.merge(observables);
     }
 }