fix another place

weidongxu-microsoft · jianghaolu · commit 3fea1187ba76 · 2021-02-04T00:11:35.000-08:00
diff --git a/azure-client-runtime/src/main/java/com/microsoft/azure/AzureClient.java b/azure-client-runtime/src/main/java/com/microsoft/azure/AzureClient.java
@@ -387,7 +387,7 @@ public Observable<PollingState<T>> call(PollingState<T> pollingState) {
                             return Observable.just(pollingState);
                         } else {
                             // initial delay
-                            return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS);
+                            return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS, Schedulers.immediate());
                         }
                     }
                 })

Original file line number	Diff line number	Diff line change
`@@ -387,7 +387,7 @@ public Observable<PollingState<T>> call(PollingState<T> pollingState) {`
`387`	`387`	`return Observable.just(pollingState);`
`388`	`388`	`} else {`
`389`	`389`	`// initial delay`
`390`		`- return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS);`
	`390`	`+ return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS, Schedulers.immediate());`
`391`	`391`	`}`
`392`	`392`	`}`
`393`	`393`	`})`