delay on Schedulers.immediate

weidongxu-microsoft · jianghaolu · commit b6163a1645b5 · 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
@@ -133,7 +133,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
`@@ -133,7 +133,7 @@ public Observable<PollingState<T>> call(PollingState<T> pollingState) {`
`133`	`133`	`return Observable.just(pollingState);`
`134`	`134`	`} else {`
`135`	`135`	`// initial delay`
`136`		`- return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS);`
	`136`	`+ return Observable.just(pollingState).delaySubscription(pollingState.delayInMilliseconds(), TimeUnit.MILLISECONDS, Schedulers.immediate());`
`137`	`137`	`}`
`138`	`138`	`}`
`139`	`139`	`})`