diff --git a/keyvault/resource-manager/v2015_06_01/pom.xml b/keyvault/resource-manager/v2015_06_01/pom.xml
index 269d75c11a90e..971e7b05841dd 100644
--- a/keyvault/resource-manager/v2015_06_01/pom.xml
+++ b/keyvault/resource-manager/v2015_06_01/pom.xml
@@ -1,133 +1,115 @@
-
-
- 4.0.0
- com.microsoft.azure.keyvault.v2015_06_01
-
- com.microsoft.azure
- azure-arm-parent
- 0.0.2-beta
- ../../../pom.xml
-
- azure-mgmt-keyvault
- 1.0.0-beta
- jar
- Microsoft Azure SDK for KeyVault Management
- This package contains Microsoft KeyVault Management SDK.
- https://github.com/Azure/azure-libraries-for-java
-
-
- The MIT License (MIT)
- http://opensource.org/licenses/MIT
- repo
-
-
-
- scm:git:https://github.com/Azure/azure-libraries-for-java
- scm:git:git@github.com:Azure/azure-libraries-for-java.git
- HEAD
-
-
- UTF-8
-
-
-
-
- microsoft
- Microsoft
-
-
-
-
- com.microsoft.azure
- azure-client-runtime
-
-
- com.microsoft.azure
- azure-arm-client-runtime
-
-
- junit
- junit
- test
-
-
- com.microsoft.azure
- azure-client-authentication
- test
-
-
- com.microsoft.azure
- azure-mgmt-resources
- test
-
-
- com.microsoft.azure
- azure-arm-client-runtime
- test-jar
- test
-
-
-
-
-
- org.apache.maven.plugins
- maven-jar-plugin
-
-
-
- true
- true
-
-
-
-
-
- org.codehaus.mojo
- build-helper-maven-plugin
-
-
- org.apache.maven.plugins
- maven-compiler-plugin
- 3.1
-
- 1.7
- 1.7
-
-
- com.microsoft.azure.management.apigeneration.LangDefinitionProcessor
-
-
- true
- true
-
- true
- true
-
-
-
-
- org.apache.maven.plugins
- maven-javadoc-plugin
- 2.8
-
- *.implementation.*;*.utils.*;com.microsoft.schemas._2003._10.serialization;*.blob.core.search
-
-
- /**
- * Copyright (c) Microsoft Corporation. All rights reserved.
- * Licensed under the MIT License. See License.txt in the project root for
- * license information.
- */
- ]]>
-
-
-
-
-
-
+
+
+ 4.0.0
+ com.microsoft.azure
+ azure-keyvault
+ 1.7.1-SNAPSHOT
+ jar
+ Microsoft Azure SDK for KeyVault
+ This package contains Microsoft KeyVault SDK.
+ https://github.com/Azure/azure-sdk-for-java
+
+
+ The MIT License (MIT)
+ http://opensource.org/licenses/MIT
+ repo
+
+
+
+ scm:git:https://github.com/Azure/azure-sdk-for-java
+ scm:git:git@github.com:Azure/azure-sdk-for-java.git
+ HEAD
+
+
+ UTF-8
+
+
+
+
+ microsoft
+ Microsoft
+
+
+
+
+ com.microsoft.azure
+ azure-client-runtime
+ 1.3.0
+
+
+ junit
+ junit
+ 4.12
+ test
+
+
+ com.microsoft.azure
+ azure-client-authentication
+ 1.3.0
+ test
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-jar-plugin
+
+
+
+ true
+ true
+
+
+
+
+
+ org.codehaus.mojo
+ build-helper-maven-plugin
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.1
+
+ 1.7
+ 1.7
+
+
+ com.microsoft.azure.management.apigeneration.LangDefinitionProcessor
+
+
+ true
+ true
+
+ true
+ true
+
+
+
+
+ org.apache.maven.plugins
+ maven-javadoc-plugin
+ 2.8
+
+ *.implementation.*;*.utils.*;com.microsoft.schemas._2003._10.serialization;*.blob.core.search
+
+
+ /**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ */
+ ]]>
+
+
+
+
+
+
diff --git a/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/KeyVaultManagementClient.java b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/KeyVaultManagementClient.java
new file mode 100644
index 0000000000000..d57972e425cff
--- /dev/null
+++ b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/KeyVaultManagementClient.java
@@ -0,0 +1,111 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.keyvault.v2015_06_01;
+
+import com.microsoft.azure.AzureClient;
+import com.microsoft.rest.RestClient;
+
+/**
+ * The interface for KeyVaultManagementClient class.
+ */
+public interface KeyVaultManagementClient {
+ /**
+ * Gets the REST client.
+ *
+ * @return the {@link RestClient} object.
+ */
+ RestClient restClient();
+
+ /**
+ * Gets the {@link AzureClient} used for long running operations.
+ * @return the azure client;
+ */
+ AzureClient getAzureClient();
+
+ /**
+ * Gets the User-Agent header for the client.
+ *
+ * @return the user agent string.
+ */
+ String userAgent();
+
+ /**
+ * Gets Gets subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call..
+ *
+ * @return the subscriptionId value.
+ */
+ String subscriptionId();
+
+ /**
+ * Sets Gets subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call..
+ *
+ * @param subscriptionId the subscriptionId value.
+ * @return the service client itself
+ */
+ KeyVaultManagementClient withSubscriptionId(String subscriptionId);
+
+ /**
+ * Gets Client Api Version..
+ *
+ * @return the apiVersion value.
+ */
+ String apiVersion();
+
+ /**
+ * Gets Gets or sets the preferred language for the response..
+ *
+ * @return the acceptLanguage value.
+ */
+ String acceptLanguage();
+
+ /**
+ * Sets Gets or sets the preferred language for the response..
+ *
+ * @param acceptLanguage the acceptLanguage value.
+ * @return the service client itself
+ */
+ KeyVaultManagementClient withAcceptLanguage(String acceptLanguage);
+
+ /**
+ * Gets Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30..
+ *
+ * @return the longRunningOperationRetryTimeout value.
+ */
+ int longRunningOperationRetryTimeout();
+
+ /**
+ * Sets Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30..
+ *
+ * @param longRunningOperationRetryTimeout the longRunningOperationRetryTimeout value.
+ * @return the service client itself
+ */
+ KeyVaultManagementClient withLongRunningOperationRetryTimeout(int longRunningOperationRetryTimeout);
+
+ /**
+ * Gets When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true..
+ *
+ * @return the generateClientRequestId value.
+ */
+ boolean generateClientRequestId();
+
+ /**
+ * Sets When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true..
+ *
+ * @param generateClientRequestId the generateClientRequestId value.
+ * @return the service client itself
+ */
+ KeyVaultManagementClient withGenerateClientRequestId(boolean generateClientRequestId);
+
+ /**
+ * Gets the Vaults object to access its operations.
+ * @return the Vaults object.
+ */
+ Vaults vaults();
+
+}
diff --git a/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/Vaults.java b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/Vaults.java
new file mode 100644
index 0000000000000..06fdf6885fc10
--- /dev/null
+++ b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/Vaults.java
@@ -0,0 +1,396 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.keyvault.v2015_06_01;
+
+import com.microsoft.azure.CloudException;
+import com.microsoft.azure.ListOperationCallback;
+import com.microsoft.azure.management.keyvault.v20150601.models.Vault;
+import com.microsoft.azure.management.keyvault.v20150601.models.VaultCreateOrUpdateParameters;
+import com.microsoft.azure.Page;
+import com.microsoft.azure.PagedList;
+import com.microsoft.azure.Resource;
+import com.microsoft.rest.ServiceCallback;
+import com.microsoft.rest.ServiceFuture;
+import com.microsoft.rest.ServiceResponse;
+import java.io.IOException;
+import java.util.List;
+import rx.Observable;
+
+/**
+ * An instance of this class provides access to all the operations defined
+ * in Vaults.
+ */
+public interface Vaults {
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the Vault object if successful.
+ */
+ Vault createOrUpdate(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters);
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture createOrUpdateAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters, final ServiceCallback serviceCallback);
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ Observable createOrUpdateAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters);
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ Observable> createOrUpdateWithServiceResponseAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters);
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ */
+ void delete(String resourceGroupName, String vaultName);
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture deleteAsync(String resourceGroupName, String vaultName, final ServiceCallback serviceCallback);
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceResponse} object if successful.
+ */
+ Observable deleteAsync(String resourceGroupName, String vaultName);
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceResponse} object if successful.
+ */
+ Observable> deleteWithServiceResponseAsync(String resourceGroupName, String vaultName);
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the Vault object if successful.
+ */
+ Vault get(String resourceGroupName, String vaultName);
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture getAsync(String resourceGroupName, String vaultName, final ServiceCallback serviceCallback);
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ Observable getAsync(String resourceGroupName, String vaultName);
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ Observable> getWithServiceResponseAsync(String resourceGroupName, String vaultName);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ PagedList listByResourceGroup(final String resourceGroupName);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listByResourceGroupAsync(final String resourceGroupName, final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable> listByResourceGroupAsync(final String resourceGroupName);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName);
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ PagedList listByResourceGroup(final String resourceGroupName, final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listByResourceGroupAsync(final String resourceGroupName, final Integer top, final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable> listByResourceGroupAsync(final String resourceGroupName, final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName, final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ PagedList list();
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listAsync(final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable> listAsync();
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable>> listWithServiceResponseAsync();
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ PagedList list(final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listAsync(final Integer top, final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable> listAsync(final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable>> listWithServiceResponseAsync(final Integer top);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ PagedList listByResourceGroupNext(final String nextPageLink);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @param serviceFuture the ServiceFuture object tracking the Retrofit calls
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listByResourceGroupNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable> listByResourceGroupNextAsync(final String nextPageLink);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ Observable>> listByResourceGroupNextWithServiceResponseAsync(final String nextPageLink);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ PagedList listNext(final String nextPageLink);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @param serviceFuture the ServiceFuture object tracking the Retrofit calls
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ ServiceFuture> listNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable> listNextAsync(final String nextPageLink);
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ Observable>> listNextWithServiceResponseAsync(final String nextPageLink);
+
+}
diff --git a/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/KeyVaultManagementClientImpl.java b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/KeyVaultManagementClientImpl.java
new file mode 100644
index 0000000000000..2cc403b6f5e39
--- /dev/null
+++ b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/KeyVaultManagementClientImpl.java
@@ -0,0 +1,198 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.keyvault.v2015_06_01.implementation;
+
+import com.microsoft.azure.AzureClient;
+import com.microsoft.azure.AzureServiceClient;
+import com.microsoft.azure.management.keyvault.v20150601.KeyVaultManagementClient;
+import com.microsoft.azure.management.keyvault.v20150601.Vaults;
+import com.microsoft.rest.credentials.ServiceClientCredentials;
+import com.microsoft.rest.RestClient;
+
+/**
+ * Initializes a new instance of the KeyVaultManagementClientImpl class.
+ */
+public class KeyVaultManagementClientImpl extends AzureServiceClient implements KeyVaultManagementClient {
+ /** the {@link AzureClient} used for long running operations. */
+ private AzureClient azureClient;
+
+ /**
+ * Gets the {@link AzureClient} used for long running operations.
+ * @return the azure client;
+ */
+ public AzureClient getAzureClient() {
+ return this.azureClient;
+ }
+
+ /** Gets subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. */
+ private String subscriptionId;
+
+ /**
+ * Gets Gets subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call.
+ *
+ * @return the subscriptionId value.
+ */
+ public String subscriptionId() {
+ return this.subscriptionId;
+ }
+
+ /**
+ * Sets Gets subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call.
+ *
+ * @param subscriptionId the subscriptionId value.
+ * @return the service client itself
+ */
+ public KeyVaultManagementClientImpl withSubscriptionId(String subscriptionId) {
+ this.subscriptionId = subscriptionId;
+ return this;
+ }
+
+ /** Client Api Version. */
+ private String apiVersion;
+
+ /**
+ * Gets Client Api Version.
+ *
+ * @return the apiVersion value.
+ */
+ public String apiVersion() {
+ return this.apiVersion;
+ }
+
+ /** Gets or sets the preferred language for the response. */
+ private String acceptLanguage;
+
+ /**
+ * Gets Gets or sets the preferred language for the response.
+ *
+ * @return the acceptLanguage value.
+ */
+ public String acceptLanguage() {
+ return this.acceptLanguage;
+ }
+
+ /**
+ * Sets Gets or sets the preferred language for the response.
+ *
+ * @param acceptLanguage the acceptLanguage value.
+ * @return the service client itself
+ */
+ public KeyVaultManagementClientImpl withAcceptLanguage(String acceptLanguage) {
+ this.acceptLanguage = acceptLanguage;
+ return this;
+ }
+
+ /** Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30. */
+ private int longRunningOperationRetryTimeout;
+
+ /**
+ * Gets Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30.
+ *
+ * @return the longRunningOperationRetryTimeout value.
+ */
+ public int longRunningOperationRetryTimeout() {
+ return this.longRunningOperationRetryTimeout;
+ }
+
+ /**
+ * Sets Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30.
+ *
+ * @param longRunningOperationRetryTimeout the longRunningOperationRetryTimeout value.
+ * @return the service client itself
+ */
+ public KeyVaultManagementClientImpl withLongRunningOperationRetryTimeout(int longRunningOperationRetryTimeout) {
+ this.longRunningOperationRetryTimeout = longRunningOperationRetryTimeout;
+ return this;
+ }
+
+ /** When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true. */
+ private boolean generateClientRequestId;
+
+ /**
+ * Gets When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true.
+ *
+ * @return the generateClientRequestId value.
+ */
+ public boolean generateClientRequestId() {
+ return this.generateClientRequestId;
+ }
+
+ /**
+ * Sets When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true.
+ *
+ * @param generateClientRequestId the generateClientRequestId value.
+ * @return the service client itself
+ */
+ public KeyVaultManagementClientImpl withGenerateClientRequestId(boolean generateClientRequestId) {
+ this.generateClientRequestId = generateClientRequestId;
+ return this;
+ }
+
+ /**
+ * The Vaults object to access its operations.
+ */
+ private Vaults vaults;
+
+ /**
+ * Gets the Vaults object to access its operations.
+ * @return the Vaults object.
+ */
+ public Vaults vaults() {
+ return this.vaults;
+ }
+
+ /**
+ * Initializes an instance of KeyVaultManagementClient client.
+ *
+ * @param credentials the management credentials for Azure
+ */
+ public KeyVaultManagementClientImpl(ServiceClientCredentials credentials) {
+ this("https://management.azure.com", credentials);
+ }
+
+ /**
+ * Initializes an instance of KeyVaultManagementClient client.
+ *
+ * @param baseUrl the base URL of the host
+ * @param credentials the management credentials for Azure
+ */
+ public KeyVaultManagementClientImpl(String baseUrl, ServiceClientCredentials credentials) {
+ super(baseUrl, credentials);
+ initialize();
+ }
+
+ /**
+ * Initializes an instance of KeyVaultManagementClient client.
+ *
+ * @param restClient the REST client to connect to Azure.
+ */
+ public KeyVaultManagementClientImpl(RestClient restClient) {
+ super(restClient);
+ initialize();
+ }
+
+ protected void initialize() {
+ this.apiVersion = "2015-06-01";
+ this.acceptLanguage = "en-US";
+ this.longRunningOperationRetryTimeout = 30;
+ this.generateClientRequestId = true;
+ this.vaults = new VaultsImpl(restClient().retrofit(), this);
+ this.azureClient = new AzureClient(this);
+ }
+
+ /**
+ * Gets the User-Agent header for the client.
+ *
+ * @return the user agent string.
+ */
+ @Override
+ public String userAgent() {
+ return String.format("%s (%s, %s)", super.userAgent(), "KeyVaultManagementClient", "2015-06-01");
+ }
+}
diff --git a/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/VaultsImpl.java b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/VaultsImpl.java
new file mode 100644
index 0000000000000..438cc3f903f9f
--- /dev/null
+++ b/keyvault/resource-manager/v2015_06_01/src/main/java/com/microsoft/azure/management/keyvault/v20150601/implementation/VaultsImpl.java
@@ -0,0 +1,1027 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ */
+
+package com.microsoft.azure.management.keyvault.v2015_06_01.implementation;
+
+import retrofit2.Retrofit;
+import com.microsoft.azure.management.keyvault.v20150601.Vaults;
+import com.google.common.reflect.TypeToken;
+import com.microsoft.azure.AzureServiceFuture;
+import com.microsoft.azure.CloudException;
+import com.microsoft.azure.ListOperationCallback;
+import com.microsoft.azure.management.keyvault.v20150601.models.PageImpl;
+import com.microsoft.azure.management.keyvault.v20150601.models.Vault;
+import com.microsoft.azure.management.keyvault.v20150601.models.VaultCreateOrUpdateParameters;
+import com.microsoft.azure.Page;
+import com.microsoft.azure.PagedList;
+import com.microsoft.azure.Resource;
+import com.microsoft.rest.ServiceCallback;
+import com.microsoft.rest.ServiceFuture;
+import com.microsoft.rest.ServiceResponse;
+import com.microsoft.rest.Validator;
+import java.io.IOException;
+import java.util.List;
+import okhttp3.ResponseBody;
+import retrofit2.http.Body;
+import retrofit2.http.GET;
+import retrofit2.http.Header;
+import retrofit2.http.Headers;
+import retrofit2.http.HTTP;
+import retrofit2.http.Path;
+import retrofit2.http.PUT;
+import retrofit2.http.Query;
+import retrofit2.http.Url;
+import retrofit2.Response;
+import rx.functions.Func1;
+import rx.Observable;
+
+/**
+ * An instance of this class provides access to all the operations defined
+ * in Vaults.
+ */
+public class VaultsImpl implements Vaults {
+ /** The Retrofit service to perform REST calls. */
+ private VaultsService service;
+ /** The service client containing this operation class. */
+ private KeyVaultManagementClientImpl client;
+
+ /**
+ * Initializes an instance of VaultsImpl.
+ *
+ * @param retrofit the Retrofit instance built from a Retrofit Builder.
+ * @param client the instance of the service client containing this operation class.
+ */
+ public VaultsImpl(Retrofit retrofit, KeyVaultManagementClientImpl client) {
+ this.service = retrofit.create(VaultsService.class);
+ this.client = client;
+ }
+
+ /**
+ * The interface defining all the services for Vaults to be
+ * used by Retrofit to perform actually REST calls.
+ */
+ interface VaultsService {
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults createOrUpdate" })
+ @PUT("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.KeyVault/vaults/{vaultName}")
+ Observable> createOrUpdate(@Path("resourceGroupName") String resourceGroupName, @Path("vaultName") String vaultName, @Path("subscriptionId") String subscriptionId, @Query("api-version") String apiVersion, @Body VaultCreateOrUpdateParameters parameters, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults delete" })
+ @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.KeyVault/vaults/{vaultName}", method = "DELETE", hasBody = true)
+ Observable> delete(@Path("resourceGroupName") String resourceGroupName, @Path("vaultName") String vaultName, @Path("subscriptionId") String subscriptionId, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults get" })
+ @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.KeyVault/vaults/{vaultName}")
+ Observable> get(@Path("resourceGroupName") String resourceGroupName, @Path("vaultName") String vaultName, @Path("subscriptionId") String subscriptionId, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults listByResourceGroup" })
+ @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.KeyVault/vaults")
+ Observable> listByResourceGroup(@Path("resourceGroupName") String resourceGroupName, @Path("subscriptionId") String subscriptionId, @Query("$top") Integer top, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults list" })
+ @GET("subscriptions/{subscriptionId}/resources")
+ Observable> list(@Path("subscriptionId") String subscriptionId, @Query("$filter") String filter, @Query("$top") Integer top, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults listByResourceGroupNext" })
+ @GET
+ Observable> listByResourceGroupNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.keyvault.v20150601.Vaults listNext" })
+ @GET
+ Observable> listNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
+
+ }
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the Vault object if successful.
+ */
+ public Vault createOrUpdate(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters) {
+ return createOrUpdateWithServiceResponseAsync(resourceGroupName, vaultName, parameters).toBlocking().single().body();
+ }
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture createOrUpdateAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters, final ServiceCallback serviceCallback) {
+ return ServiceFuture.fromResponse(createOrUpdateWithServiceResponseAsync(resourceGroupName, vaultName, parameters), serviceCallback);
+ }
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ public Observable createOrUpdateAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters) {
+ return createOrUpdateWithServiceResponseAsync(resourceGroupName, vaultName, parameters).map(new Func1, Vault>() {
+ @Override
+ public Vault call(ServiceResponse response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * Create or update a key vault in the specified subscription.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the server belongs.
+ * @param vaultName Name of the vault
+ * @param parameters Parameters to create or update the vault
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ public Observable> createOrUpdateWithServiceResponseAsync(String resourceGroupName, String vaultName, VaultCreateOrUpdateParameters parameters) {
+ if (resourceGroupName == null) {
+ throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+ }
+ if (vaultName == null) {
+ throw new IllegalArgumentException("Parameter vaultName is required and cannot be null.");
+ }
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ if (this.client.apiVersion() == null) {
+ throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+ }
+ if (parameters == null) {
+ throw new IllegalArgumentException("Parameter parameters is required and cannot be null.");
+ }
+ Validator.validate(parameters);
+ return service.createOrUpdate(resourceGroupName, vaultName, this.client.subscriptionId(), this.client.apiVersion(), parameters, this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>() {
+ @Override
+ public Observable> call(Response response) {
+ try {
+ ServiceResponse clientResponse = createOrUpdateDelegate(response);
+ return Observable.just(clientResponse);
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse createOrUpdateDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken() { }.getType())
+ .register(201, new TypeToken() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ */
+ public void delete(String resourceGroupName, String vaultName) {
+ deleteWithServiceResponseAsync(resourceGroupName, vaultName).toBlocking().single().body();
+ }
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture deleteAsync(String resourceGroupName, String vaultName, final ServiceCallback serviceCallback) {
+ return ServiceFuture.fromResponse(deleteWithServiceResponseAsync(resourceGroupName, vaultName), serviceCallback);
+ }
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceResponse} object if successful.
+ */
+ public Observable deleteAsync(String resourceGroupName, String vaultName) {
+ return deleteWithServiceResponseAsync(resourceGroupName, vaultName).map(new Func1, Void>() {
+ @Override
+ public Void call(ServiceResponse response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * Deletes the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault to delete
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceResponse} object if successful.
+ */
+ public Observable> deleteWithServiceResponseAsync(String resourceGroupName, String vaultName) {
+ if (resourceGroupName == null) {
+ throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+ }
+ if (vaultName == null) {
+ throw new IllegalArgumentException("Parameter vaultName is required and cannot be null.");
+ }
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ if (this.client.apiVersion() == null) {
+ throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+ }
+ return service.delete(resourceGroupName, vaultName, this.client.subscriptionId(), this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>() {
+ @Override
+ public Observable> call(Response response) {
+ try {
+ ServiceResponse clientResponse = deleteDelegate(response);
+ return Observable.just(clientResponse);
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse deleteDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the Vault object if successful.
+ */
+ public Vault get(String resourceGroupName, String vaultName) {
+ return getWithServiceResponseAsync(resourceGroupName, vaultName).toBlocking().single().body();
+ }
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture getAsync(String resourceGroupName, String vaultName, final ServiceCallback serviceCallback) {
+ return ServiceFuture.fromResponse(getWithServiceResponseAsync(resourceGroupName, vaultName), serviceCallback);
+ }
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ public Observable getAsync(String resourceGroupName, String vaultName) {
+ return getWithServiceResponseAsync(resourceGroupName, vaultName).map(new Func1, Vault>() {
+ @Override
+ public Vault call(ServiceResponse response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * Gets the specified Azure key vault.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param vaultName The name of the vault.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the Vault object
+ */
+ public Observable> getWithServiceResponseAsync(String resourceGroupName, String vaultName) {
+ if (resourceGroupName == null) {
+ throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+ }
+ if (vaultName == null) {
+ throw new IllegalArgumentException("Parameter vaultName is required and cannot be null.");
+ }
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ if (this.client.apiVersion() == null) {
+ throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+ }
+ return service.get(resourceGroupName, vaultName, this.client.subscriptionId(), this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>() {
+ @Override
+ public Observable> call(Response response) {
+ try {
+ ServiceResponse clientResponse = getDelegate(response);
+ return Observable.just(clientResponse);
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse getDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ public PagedList listByResourceGroup(final String resourceGroupName) {
+ ServiceResponse> response = listByResourceGroupSinglePageAsync(resourceGroupName).toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listByResourceGroupAsync(final String resourceGroupName, final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listByResourceGroupSinglePageAsync(resourceGroupName),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable> listByResourceGroupAsync(final String resourceGroupName) {
+ return listByResourceGroupWithServiceResponseAsync(resourceGroupName)
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName) {
+ return listByResourceGroupSinglePageAsync(resourceGroupName)
+ .concatMap(new Func1>, Observable>>>() {
+ @Override
+ public Observable>> call(ServiceResponse> page) {
+ String nextPageLink = page.body().nextPageLink();
+ if (nextPageLink == null) {
+ return Observable.just(page);
+ }
+ return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the PagedList<Vault> object wrapped in {@link ServiceResponse} if successful.
+ */
+ public Observable>> listByResourceGroupSinglePageAsync(final String resourceGroupName) {
+ if (resourceGroupName == null) {
+ throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+ }
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ if (this.client.apiVersion() == null) {
+ throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+ }
+ final Integer top = null;
+ return service.listByResourceGroup(resourceGroupName, this.client.subscriptionId(), top, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>>() {
+ @Override
+ public Observable>> call(Response response) {
+ try {
+ ServiceResponse> result = listByResourceGroupDelegate(response);
+ return Observable.just(new ServiceResponse>(result.body(), result.response()));
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ public PagedList listByResourceGroup(final String resourceGroupName, final Integer top) {
+ ServiceResponse> response = listByResourceGroupSinglePageAsync(resourceGroupName, top).toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listByResourceGroupAsync(final String resourceGroupName, final Integer top, final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listByResourceGroupSinglePageAsync(resourceGroupName, top),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable> listByResourceGroupAsync(final String resourceGroupName, final Integer top) {
+ return listByResourceGroupWithServiceResponseAsync(resourceGroupName, top)
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName, final Integer top) {
+ return listByResourceGroupSinglePageAsync(resourceGroupName, top)
+ .concatMap(new Func1>, Observable>>>() {
+ @Override
+ public Observable>> call(ServiceResponse> page) {
+ String nextPageLink = page.body().nextPageLink();
+ if (nextPageLink == null) {
+ return Observable.just(page);
+ }
+ return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ ServiceResponse> * @param resourceGroupName The name of the Resource Group to which the vault belongs.
+ ServiceResponse> * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the PagedList<Vault> object wrapped in {@link ServiceResponse} if successful.
+ */
+ public Observable>> listByResourceGroupSinglePageAsync(final String resourceGroupName, final Integer top) {
+ if (resourceGroupName == null) {
+ throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+ }
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ if (this.client.apiVersion() == null) {
+ throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+ }
+ return service.listByResourceGroup(resourceGroupName, this.client.subscriptionId(), top, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>>() {
+ @Override
+ public Observable>> call(Response response) {
+ try {
+ ServiceResponse> result = listByResourceGroupDelegate(response);
+ return Observable.just(new ServiceResponse>(result.body(), result.response()));
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse> listByResourceGroupDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory()., CloudException>newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken>() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ public PagedList list() {
+ ServiceResponse> response = listSinglePageAsync().toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listAsync(final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listSinglePageAsync(),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable> listAsync() {
+ return listWithServiceResponseAsync()
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable>> listWithServiceResponseAsync() {
+ return listSinglePageAsync()
+ .concatMap(new Func1>, Observable>>>() {
+ @Override
+ public Observable>> call(ServiceResponse> page) {
+ String nextPageLink = page.body().nextPageLink();
+ if (nextPageLink == null) {
+ return Observable.just(page);
+ }
+ return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the PagedList<Resource> object wrapped in {@link ServiceResponse} if successful.
+ */
+ public Observable>> listSinglePageAsync() {
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ final String filter = "resourceType eq 'Microsoft.KeyVault/vaults'";
+ final String apiVersion = "2015-11-01";
+ final Integer top = null;
+ return service.list(this.client.subscriptionId(), filter, top, apiVersion, this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>>() {
+ @Override
+ public Observable>> call(Response response) {
+ try {
+ ServiceResponse> result = listDelegate(response);
+ return Observable.just(new ServiceResponse>(result.body(), result.response()));
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ public PagedList list(final Integer top) {
+ ServiceResponse> response = listSinglePageAsync(top).toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listAsync(final Integer top, final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listSinglePageAsync(top),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable> listAsync(final Integer top) {
+ return listWithServiceResponseAsync(top)
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable>> listWithServiceResponseAsync(final Integer top) {
+ return listSinglePageAsync(top)
+ .concatMap(new Func1>, Observable>>>() {
+ @Override
+ public Observable>> call(ServiceResponse> page) {
+ String nextPageLink = page.body().nextPageLink();
+ if (nextPageLink == null) {
+ return Observable.just(page);
+ }
+ return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ ServiceResponse> * @param top Maximum number of results to return.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the PagedList<Resource> object wrapped in {@link ServiceResponse} if successful.
+ */
+ public Observable>> listSinglePageAsync(final Integer top) {
+ if (this.client.subscriptionId() == null) {
+ throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+ }
+ final String filter = "resourceType eq 'Microsoft.KeyVault/vaults'";
+ final String apiVersion = "2015-11-01";
+ return service.list(this.client.subscriptionId(), filter, top, apiVersion, this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>>() {
+ @Override
+ public Observable>> call(Response response) {
+ try {
+ ServiceResponse> result = listDelegate(response);
+ return Observable.just(new ServiceResponse>(result.body(), result.response()));
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse> listDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory()., CloudException>newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken>() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Vault> object if successful.
+ */
+ public PagedList listByResourceGroupNext(final String nextPageLink) {
+ ServiceResponse> response = listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @param serviceFuture the ServiceFuture object tracking the Retrofit calls
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listByResourceGroupNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listByResourceGroupNextSinglePageAsync(nextPageLink),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable> listByResourceGroupNextAsync(final String nextPageLink) {
+ return listByResourceGroupNextWithServiceResponseAsync(nextPageLink)
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Vault> object
+ */
+ public Observable>> listByResourceGroupNextWithServiceResponseAsync(final String nextPageLink) {
+ return listByResourceGroupNextSinglePageAsync(nextPageLink)
+ .concatMap(new Func1>, Observable>>>() {
+ @Override
+ public Observable>> call(ServiceResponse> page) {
+ String nextPageLink = page.body().nextPageLink();
+ if (nextPageLink == null) {
+ return Observable.just(page);
+ }
+ return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription and within the specified resource group.
+ *
+ ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the PagedList<Vault> object wrapped in {@link ServiceResponse} if successful.
+ */
+ public Observable>> listByResourceGroupNextSinglePageAsync(final String nextPageLink) {
+ if (nextPageLink == null) {
+ throw new IllegalArgumentException("Parameter nextPageLink is required and cannot be null.");
+ }
+ String nextUrl = String.format("%s", nextPageLink);
+ return service.listByResourceGroupNext(nextUrl, this.client.acceptLanguage(), this.client.userAgent())
+ .flatMap(new Func1, Observable>>>() {
+ @Override
+ public Observable>> call(Response response) {
+ try {
+ ServiceResponse> result = listByResourceGroupNextDelegate(response);
+ return Observable.just(new ServiceResponse>(result.body(), result.response()));
+ } catch (Throwable t) {
+ return Observable.error(t);
+ }
+ }
+ });
+ }
+
+ private ServiceResponse> listByResourceGroupNextDelegate(Response response) throws CloudException, IOException, IllegalArgumentException {
+ return this.client.restClient().responseBuilderFactory()., CloudException>newInstance(this.client.serializerAdapter())
+ .register(200, new TypeToken>() { }.getType())
+ .registerError(CloudException.class)
+ .build(response);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @throws CloudException thrown if the request is rejected by server
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+ * @return the PagedList<Resource> object if successful.
+ */
+ public PagedList listNext(final String nextPageLink) {
+ ServiceResponse> response = listNextSinglePageAsync(nextPageLink).toBlocking().single();
+ return new PagedList(response.body()) {
+ @Override
+ public Page nextPage(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink).toBlocking().single().body();
+ }
+ };
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @param serviceFuture the ServiceFuture object tracking the Retrofit calls
+ * @param serviceCallback the async ServiceCallback to handle successful and failed responses.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the {@link ServiceFuture} object
+ */
+ public ServiceFuture> listNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback) {
+ return AzureServiceFuture.fromPageResponse(
+ listNextSinglePageAsync(nextPageLink),
+ new Func1>>>() {
+ @Override
+ public Observable>> call(String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink);
+ }
+ },
+ serviceCallback);
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable> listNextAsync(final String nextPageLink) {
+ return listNextWithServiceResponseAsync(nextPageLink)
+ .map(new Func1>, Page>() {
+ @Override
+ public Page call(ServiceResponse> response) {
+ return response.body();
+ }
+ });
+ }
+
+ /**
+ * The List operation gets information about the vaults associated with the subscription.
+ *
+ * @param nextPageLink The NextLink from the previous successful call to List operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation
+ * @return the observable to the PagedList<Resource> object
+ */
+ public Observable>> listNextWithServiceResponseAsync(final String nextPageLink) {
+ return listNextSinglePageAsync(nextPageLink)
+ .concatMap(new Func1