use SdkContext.getRxScheduler() for other forceDeletion APIs (#1431)

Author: weidongxu-microsoft

azure-mgmt-compute/src/main/java/com/microsoft/azure/management/compute/implementation/VirtualMachineScaleSetVMsImpl.java

@@ -82,8 +82,8 @@ public void deleteInstances(String... instanceIds) {
 
     @Override
     public Completable deleteInstancesAsync(Collection<String> instanceIds, boolean forceDeletion) {
-        return this.scaleSet.manager().virtualMachineScaleSets().deleteInstancesAsync(this.scaleSet.resourceGroupName(),
-                this.scaleSet.name(), instanceIds, forceDeletion);
+        return this.scaleSet.manager().virtualMachineScaleSets().deleteInstancesAsync(
+                this.scaleSet.resourceGroupName(), this.scaleSet.name(), instanceIds, forceDeletion);
     }
 
     @Override

azure-mgmt-compute/src/main/java/com/microsoft/azure/management/compute/implementation/VirtualMachineScaleSetsImpl.java

@@ -22,6 +22,7 @@
 import com.microsoft.azure.management.network.implementation.NetworkManager;
 import com.microsoft.azure.management.resources.fluentcore.arm.ResourceUtils;
 import com.microsoft.azure.management.resources.fluentcore.arm.collection.implementation.TopLevelModifiableResourcesImpl;
+import com.microsoft.azure.management.resources.fluentcore.utils.SdkContext;
 import com.microsoft.azure.management.storage.implementation.StorageManager;
 import com.microsoft.rest.ServiceCallback;
 import com.microsoft.rest.ServiceFuture;
@@ -192,7 +193,7 @@ public Completable deleteInstancesAsync(String groupName, String scaleSetName, C
             return Completable.complete();
         }
         return this.manager().inner().virtualMachineScaleSets().deleteInstancesAsync(groupName, scaleSetName,
-                new ArrayList<>(instanceIds), forceDeletion).toCompletable();
+                new ArrayList<>(instanceIds), forceDeletion).toCompletable().subscribeOn(SdkContext.getRxScheduler());
     }
 
     @Override
@@ -290,6 +291,6 @@ public ServiceFuture<Void> deleteByResourceGroupAsync(String resourceGroupName,
 
     @Override
     public Completable deleteByResourceGroupAsync(String resourceGroupName, String name, boolean forceDeletion) {
-        return this.inner().deleteAsync(resourceGroupName, name, forceDeletion).toCompletable();
+        return this.inner().deleteAsync(resourceGroupName, name, forceDeletion).toCompletable().subscribeOn(SdkContext.getRxScheduler());
     }
 }

azure-mgmt-resources/src/main/java/com/microsoft/azure/management/resources/implementation/GenericResourcesImpl.java

@@ -16,6 +16,7 @@
 import com.microsoft.azure.management.resources.fluentcore.arm.ResourceUtils;
 import com.microsoft.azure.management.resources.fluentcore.arm.collection.implementation.GroupableResourcesImpl;
 import com.microsoft.azure.management.resources.fluentcore.utils.PagedListConverter;
+import com.microsoft.azure.management.resources.fluentcore.utils.SdkContext;
 import com.microsoft.azure.management.resources.fluentcore.utils.Utils;
 import com.microsoft.rest.ServiceCallback;
 import com.microsoft.rest.ServiceFuture;
@@ -251,7 +252,8 @@ public void delete(String resourceGroupName, String resourceProviderNamespace, S
 
     @Override
     public Completable deleteAsync(String resourceGroupName, String resourceProviderNamespace, String parentResourcePath, String resourceType, String resourceName, String apiVersion, boolean forceDeletion) {
-        return this.inner().deleteAsync(resourceGroupName, resourceProviderNamespace, parentResourcePath, resourceType, resourceName, apiVersion, forceDeletion).toCompletable();
+        return this.inner().deleteAsync(resourceGroupName, resourceProviderNamespace, parentResourcePath, resourceType, resourceName, apiVersion, forceDeletion).toCompletable()
+                .subscribeOn(SdkContext.getRxScheduler());
     }
 
     @Override

azure-mgmt-resources/src/main/java/com/microsoft/azure/management/resources/implementation/ResourceGroupsImpl.java

@@ -13,6 +13,7 @@
 import com.microsoft.azure.management.resources.ResourceGroups;
 import com.microsoft.azure.management.resources.fluentcore.arm.ResourceUtils;
 import com.microsoft.azure.management.resources.fluentcore.arm.collection.implementation.CreatableResourcesImpl;
+import com.microsoft.azure.management.resources.fluentcore.utils.SdkContext;
 import com.microsoft.azure.management.resources.fluentcore.utils.Utils;
 import com.microsoft.rest.ServiceFuture;
 import com.microsoft.rest.ServiceCallback;
@@ -102,7 +103,7 @@ public ServiceFuture<Void> deleteByNameAsync(String name, Collection<ForceDeleti
 
     @Override
     public Completable deleteByNameAsync(String name, Collection<ForceDeletionResourceType> forceDeletionResourceTypes) {
-        return client.deleteAsync(name, forceDeletionTypes(forceDeletionResourceTypes)).toCompletable();
+        return client.deleteAsync(name, forceDeletionTypes(forceDeletionResourceTypes)).toCompletable().subscribeOn(SdkContext.getRxScheduler());
     }
 
     private static String forceDeletionTypes(Collection<ForceDeletionResourceType> forceDeletionResourceTypes) {