Merge branch 'qianjin-bugfix-20210112' of https://github.com/microsoft/azure-tools-for-java into qianjin-bugfix-20210112

Author: shenqianjin

Utils/azuretools-core/src/com/microsoft/azure/toolkit/lib/common/task/AzureTaskManager.java

@@ -25,7 +25,6 @@
 import lombok.extern.java.Log;
 import rx.Emitter;
 import rx.Observable;
-import rx.observables.ConnectableObservable;
 
 import java.util.function.BiConsumer;
 import java.util.function.Supplier;
@@ -253,8 +252,8 @@ public final <T> Observable<T> runInModalAsObservable(AzureTask<T> task) {
         return this.runInObservable(this::doRunInModal, task);
     }
 
-    private <T> ConnectableObservable<T> runInObservable(final BiConsumer<? super Runnable, ? super AzureTask<T>> consumer, final AzureTask<T> task) {
-        final ConnectableObservable<T> observable = Observable.create((Emitter<T> emitter) -> {
+    private <T> Observable<T> runInObservable(final BiConsumer<? super Runnable, ? super AzureTask<T>> consumer, final AzureTask<T> task) {
+        return Observable.create((Emitter<T> emitter) -> {
             final AzureTaskContext.Node context = AzureTaskContext.current().derive();
             task.setContext(context);
             context.setTask(task);
@@ -268,9 +267,7 @@ private <T> ConnectableObservable<T> runInObservable(final BiConsumer<? super Ru
                 }
             }, context);
             consumer.accept(t, task);
-        }, Emitter.BackpressureMode.BUFFER).publish();
-        observable.connect();
-        return observable;
+        }, Emitter.BackpressureMode.BUFFER);
     }
 
     protected abstract void doRead(Runnable runnable, AzureTask<?> task);