com.microsoft.azure/azure-mgmt-network/1.41.0 : com/microsoft/azure/management/network/implementation/FirewallPoliciesInner.java

FirewallPoliciesInner
https://github.com/Azure/azure-sdk-for-java: This package contains Microsoft Azure Network Management SDK. A new set of management libraries are now Generally Available. For documentation on how to use the new libraries, please see https://aka.ms/azsdk/java/mgmt
The MIT License (MIT)
Microsoft
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.
/**
 * 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.network.implementation;

import com.microsoft.azure.management.resources.fluentcore.collection.InnerSupportsGet;
import com.microsoft.azure.management.resources.fluentcore.collection.InnerSupportsDelete;
import com.microsoft.azure.management.resources.fluentcore.collection.InnerSupportsListing;
import retrofit2.Retrofit;
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.Page;
import com.microsoft.azure.PagedList;
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 FirewallPolicies.
/**
 * An instance of this class provides access to all the operations defined
 * in FirewallPolicies.
 */
public class FirewallPoliciesInner implements InnerSupportsGet<FirewallPolicyInner>, InnerSupportsDelete<Void>, InnerSupportsListing<FirewallPolicyInner> {
    The Retrofit service to perform REST calls. /** The Retrofit service to perform REST calls. */
    private FirewallPoliciesService service;
    The service client containing this operation class. /** The service client containing this operation class. */
    private NetworkManagementClientImpl client;

    Initializes an instance of FirewallPoliciesInner.
Params: retrofit – the Retrofit instance built from a Retrofit Builder.
client – the instance of the service client containing this operation class./**
     * Initializes an instance of FirewallPoliciesInner.
     *
     * @param retrofit the Retrofit instance built from a Retrofit Builder.
     * @param client the instance of the service client containing this operation class.
     */
    public FirewallPoliciesInner(Retrofit retrofit, NetworkManagementClientImpl client) {
        this.service = retrofit.create(FirewallPoliciesService.class);
        this.client = client;
    }

    The interface defining all the services for FirewallPolicies to be
used by Retrofit to perform actually REST calls.
/**
     * The interface defining all the services for FirewallPolicies to be
     * used by Retrofit to perform actually REST calls.
     */
    interface FirewallPoliciesService {
        @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.network.FirewallPolicies delete" })
        @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies/{firewallPolicyName}", method = "DELETE", hasBody = true)
        Observable<Response<ResponseBody>> delete(@Path("resourceGroupName") String resourceGroupName, @Path("firewallPolicyName") String firewallPolicyName, @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.network.FirewallPolicies beginDelete" })
        @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies/{firewallPolicyName}", method = "DELETE", hasBody = true)
        Observable<Response<ResponseBody>> beginDelete(@Path("resourceGroupName") String resourceGroupName, @Path("firewallPolicyName") String firewallPolicyName, @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.network.FirewallPolicies getByResourceGroup" })
        @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies/{firewallPolicyName}")
        Observable<Response<ResponseBody>> getByResourceGroup(@Path("resourceGroupName") String resourceGroupName, @Path("firewallPolicyName") String firewallPolicyName, @Path("subscriptionId") String subscriptionId, @Query("api-version") String apiVersion, @Query("$expand") String expand, @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.network.FirewallPolicies createOrUpdate" })
        @PUT("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies/{firewallPolicyName}")
        Observable<Response<ResponseBody>> createOrUpdate(@Path("resourceGroupName") String resourceGroupName, @Path("firewallPolicyName") String firewallPolicyName, @Path("subscriptionId") String subscriptionId, @Body FirewallPolicyInner parameters, @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.network.FirewallPolicies beginCreateOrUpdate" })
        @PUT("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies/{firewallPolicyName}")
        Observable<Response<ResponseBody>> beginCreateOrUpdate(@Path("resourceGroupName") String resourceGroupName, @Path("firewallPolicyName") String firewallPolicyName, @Path("subscriptionId") String subscriptionId, @Body FirewallPolicyInner parameters, @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.network.FirewallPolicies listByResourceGroup" })
        @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/firewallPolicies")
        Observable<Response<ResponseBody>> listByResourceGroup(@Path("resourceGroupName") String resourceGroupName, @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.network.FirewallPolicies list" })
        @GET("subscriptions/{subscriptionId}/providers/Microsoft.Network/firewallPolicies")
        Observable<Response<ResponseBody>> list(@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.network.FirewallPolicies listByResourceGroupNext" })
        @GET
        Observable<Response<ResponseBody>> 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.network.FirewallPolicies listNext" })
        @GET
        Observable<Response<ResponseBody>> listNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);

    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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 firewallPolicyName) {
        deleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName).toBlocking().last().body();
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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<Void> deleteAsync(String resourceGroupName, String firewallPolicyName, final ServiceCallback<Void> serviceCallback) {
        return ServiceFuture.fromResponse(deleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName), serviceCallback);
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable for the request/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable for the request
     */
    public Observable<Void> deleteAsync(String resourceGroupName, String firewallPolicyName) {
        return deleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName).map(new Func1<ServiceResponse<Void>, Void>() {
            @Override
            public Void call(ServiceResponse<Void> response) {
                return response.body();
            }
        });
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable for the request/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable for the request
     */
    public Observable<ServiceResponse<Void>> deleteWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName is required and cannot be null.");
        }
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2019-11-01";
        Observable<Response<ResponseBody>> observable = service.delete(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), apiVersion, this.client.acceptLanguage(), this.client.userAgent());
        return client.getAzureClient().getPostOrDeleteResultAsync(observable, new TypeToken<Void>() { }.getType());
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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 beginDelete(String resourceGroupName, String firewallPolicyName) {
        beginDeleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName).toBlocking().single().body();
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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<Void> beginDeleteAsync(String resourceGroupName, String firewallPolicyName, final ServiceCallback<Void> serviceCallback) {
        return ServiceFuture.fromResponse(beginDeleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName), serviceCallback);
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceResponse object if successful./**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the {@link ServiceResponse} object if successful.
     */
    public Observable<Void> beginDeleteAsync(String resourceGroupName, String firewallPolicyName) {
        return beginDeleteWithServiceResponseAsync(resourceGroupName, firewallPolicyName).map(new Func1<ServiceResponse<Void>, Void>() {
            @Override
            public Void call(ServiceResponse<Void> response) {
                return response.body();
            }
        });
    }

    Deletes the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceResponse object if successful./**
     * Deletes the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the {@link ServiceResponse} object if successful.
     */
    public Observable<ServiceResponse<Void>> beginDeleteWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName is required and cannot be null.");
        }
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2019-11-01";
        return service.beginDelete(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), apiVersion, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Void>>>() {
                @Override
                public Observable<ServiceResponse<Void>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<Void> clientResponse = beginDeleteDelegate(response);
                        return Observable.just(clientResponse);
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<Void> beginDeleteDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<Void, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<Void>() { }.getType())
                .register(202, new TypeToken<Void>() { }.getType())
                .register(204, new TypeToken<Void>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the FirewallPolicyInner object if successful./**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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 FirewallPolicyInner object if successful.
     */
    public FirewallPolicyInner getByResourceGroup(String resourceGroupName, String firewallPolicyName) {
        return getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName).toBlocking().single().body();
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @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<FirewallPolicyInner> getByResourceGroupAsync(String resourceGroupName, String firewallPolicyName, final ServiceCallback<FirewallPolicyInner> serviceCallback) {
        return ServiceFuture.fromResponse(getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName), serviceCallback);
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<FirewallPolicyInner> getByResourceGroupAsync(String resourceGroupName, String firewallPolicyName) {
        return getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName).map(new Func1<ServiceResponse<FirewallPolicyInner>, FirewallPolicyInner>() {
            @Override
            public FirewallPolicyInner call(ServiceResponse<FirewallPolicyInner> response) {
                return response.body();
            }
        });
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<ServiceResponse<FirewallPolicyInner>> getByResourceGroupWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName is required and cannot be null.");
        }
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2019-11-01";
        final String expand = null;
        return service.getByResourceGroup(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), apiVersion, expand, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<FirewallPolicyInner>>>() {
                @Override
                public Observable<ServiceResponse<FirewallPolicyInner>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<FirewallPolicyInner> clientResponse = getByResourceGroupDelegate(response);
                        return Observable.just(clientResponse);
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
expand – Expands referenced resources.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the FirewallPolicyInner object if successful./**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param expand Expands referenced resources.
     * @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 FirewallPolicyInner object if successful.
     */
    public FirewallPolicyInner getByResourceGroup(String resourceGroupName, String firewallPolicyName, String expand) {
        return getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName, expand).toBlocking().single().body();
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
expand – Expands referenced resources.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param expand Expands referenced resources.
     * @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<FirewallPolicyInner> getByResourceGroupAsync(String resourceGroupName, String firewallPolicyName, String expand, final ServiceCallback<FirewallPolicyInner> serviceCallback) {
        return ServiceFuture.fromResponse(getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName, expand), serviceCallback);
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
expand – Expands referenced resources.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param expand Expands referenced resources.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<FirewallPolicyInner> getByResourceGroupAsync(String resourceGroupName, String firewallPolicyName, String expand) {
        return getByResourceGroupWithServiceResponseAsync(resourceGroupName, firewallPolicyName, expand).map(new Func1<ServiceResponse<FirewallPolicyInner>, FirewallPolicyInner>() {
            @Override
            public FirewallPolicyInner call(ServiceResponse<FirewallPolicyInner> response) {
                return response.body();
            }
        });
    }

    Gets the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
expand – Expands referenced resources.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Gets the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param expand Expands referenced resources.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<ServiceResponse<FirewallPolicyInner>> getByResourceGroupWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName, String expand) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName is required and cannot be null.");
        }
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2019-11-01";
        return service.getByResourceGroup(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), apiVersion, expand, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<FirewallPolicyInner>>>() {
                @Override
                public Observable<ServiceResponse<FirewallPolicyInner>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<FirewallPolicyInner> clientResponse = getByResourceGroupDelegate(response);
                        return Observable.just(clientResponse);
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<FirewallPolicyInner> getByResourceGroupDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<FirewallPolicyInner, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<FirewallPolicyInner>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the FirewallPolicyInner object if successful./**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy 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 FirewallPolicyInner object if successful.
     */
    public FirewallPolicyInner createOrUpdate(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        return createOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters).toBlocking().last().body();
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @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<FirewallPolicyInner> createOrUpdateAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters, final ServiceCallback<FirewallPolicyInner> serviceCallback) {
        return ServiceFuture.fromResponse(createOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters), serviceCallback);
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable for the request/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable for the request
     */
    public Observable<FirewallPolicyInner> createOrUpdateAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        return createOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters).map(new Func1<ServiceResponse<FirewallPolicyInner>, FirewallPolicyInner>() {
            @Override
            public FirewallPolicyInner call(ServiceResponse<FirewallPolicyInner> response) {
                return response.body();
            }
        });
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable for the request/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable for the request
     */
    public Observable<ServiceResponse<FirewallPolicyInner>> createOrUpdateWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName 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 (parameters == null) {
            throw new IllegalArgumentException("Parameter parameters is required and cannot be null.");
        }
        Validator.validate(parameters);
        final String apiVersion = "2019-11-01";
        Observable<Response<ResponseBody>> observable = service.createOrUpdate(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), parameters, apiVersion, this.client.acceptLanguage(), this.client.userAgent());
        return client.getAzureClient().getPutOrPatchResultAsync(observable, new TypeToken<FirewallPolicyInner>() { }.getType());
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the FirewallPolicyInner object if successful./**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy 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 FirewallPolicyInner object if successful.
     */
    public FirewallPolicyInner beginCreateOrUpdate(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        return beginCreateOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters).toBlocking().single().body();
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @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<FirewallPolicyInner> beginCreateOrUpdateAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters, final ServiceCallback<FirewallPolicyInner> serviceCallback) {
        return ServiceFuture.fromResponse(beginCreateOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters), serviceCallback);
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<FirewallPolicyInner> beginCreateOrUpdateAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        return beginCreateOrUpdateWithServiceResponseAsync(resourceGroupName, firewallPolicyName, parameters).map(new Func1<ServiceResponse<FirewallPolicyInner>, FirewallPolicyInner>() {
            @Override
            public FirewallPolicyInner call(ServiceResponse<FirewallPolicyInner> response) {
                return response.body();
            }
        });
    }

    Creates or updates the specified Firewall Policy.
Params: resourceGroupName – The name of the resource group.
firewallPolicyName – The name of the Firewall Policy.
parameters – Parameters supplied to the create or update Firewall Policy operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the FirewallPolicyInner object/**
     * Creates or updates the specified Firewall Policy.
     *
     * @param resourceGroupName The name of the resource group.
     * @param firewallPolicyName The name of the Firewall Policy.
     * @param parameters Parameters supplied to the create or update Firewall Policy operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the FirewallPolicyInner object
     */
    public Observable<ServiceResponse<FirewallPolicyInner>> beginCreateOrUpdateWithServiceResponseAsync(String resourceGroupName, String firewallPolicyName, FirewallPolicyInner parameters) {
        if (resourceGroupName == null) {
            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
        }
        if (firewallPolicyName == null) {
            throw new IllegalArgumentException("Parameter firewallPolicyName 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 (parameters == null) {
            throw new IllegalArgumentException("Parameter parameters is required and cannot be null.");
        }
        Validator.validate(parameters);
        final String apiVersion = "2019-11-01";
        return service.beginCreateOrUpdate(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), parameters, apiVersion, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<FirewallPolicyInner>>>() {
                @Override
                public Observable<ServiceResponse<FirewallPolicyInner>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<FirewallPolicyInner> clientResponse = beginCreateOrUpdateDelegate(response);
                        return Observable.just(clientResponse);
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<FirewallPolicyInner> beginCreateOrUpdateDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<FirewallPolicyInner, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<FirewallPolicyInner>() { }.getType())
                .register(201, new TypeToken<FirewallPolicyInner>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Lists all Firewall Policies in a resource group.
Params: resourceGroupName – The name of the resource group.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the PagedList<FirewallPolicyInner> object if successful./**
     * Lists all Firewall Policies in a resource group.
     *
     * @param resourceGroupName The name of the resource group.
     * @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&lt;FirewallPolicyInner&gt; object if successful.
     */
    public PagedList<FirewallPolicyInner> listByResourceGroup(final String resourceGroupName) {
        ServiceResponse<Page<FirewallPolicyInner>> response = listByResourceGroupSinglePageAsync(resourceGroupName).toBlocking().single();
        return new PagedList<FirewallPolicyInner>(response.body()) {
            @Override
            public Page<FirewallPolicyInner> nextPage(String nextPageLink) {
                return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body();
            }
        };
    }

    Lists all Firewall Policies in a resource group.
Params: resourceGroupName – The name of the resource group.
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Lists all Firewall Policies in a resource group.
     *
     * @param resourceGroupName The name of the resource group.
     * @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<List<FirewallPolicyInner>> listByResourceGroupAsync(final String resourceGroupName, final ListOperationCallback<FirewallPolicyInner> serviceCallback) {
        return AzureServiceFuture.fromPageResponse(
            listByResourceGroupSinglePageAsync(resourceGroupName),
            new Func1<String, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(String nextPageLink) {
                    return listByResourceGroupNextSinglePageAsync(nextPageLink);
                }
            },
            serviceCallback);
    }

    Lists all Firewall Policies in a resource group.
Params: resourceGroupName – The name of the resource group.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Lists all Firewall Policies in a resource group.
     *
     * @param resourceGroupName The name of the resource group.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the PagedList&lt;FirewallPolicyInner&gt; object
     */
    public Observable<Page<FirewallPolicyInner>> listByResourceGroupAsync(final String resourceGroupName) {
        return listByResourceGroupWithServiceResponseAsync(resourceGroupName)
            .map(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Page<FirewallPolicyInner>>() {
                @Override
                public Page<FirewallPolicyInner> call(ServiceResponse<Page<FirewallPolicyInner>> response) {
                    return response.body();
                }
            });
    }

    Lists all Firewall Policies in a resource group.
Params: resourceGroupName – The name of the resource group.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Lists all Firewall Policies in a resource group.
     *
     * @param resourceGroupName The name of the resource group.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the PagedList&lt;FirewallPolicyInner&gt; object
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName) {
        return listByResourceGroupSinglePageAsync(resourceGroupName)
            .concatMap(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(ServiceResponse<Page<FirewallPolicyInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }

    Lists all Firewall Policies in a resource group.
ServiceResponse> * @param resourceGroupName The name of the resource group.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the PagedList<FirewallPolicyInner> object wrapped in ServiceResponse if successful./**
     * Lists all Firewall Policies in a resource group.
     *
    ServiceResponse<PageImpl<FirewallPolicyInner>> * @param resourceGroupName The name of the resource group.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the PagedList&lt;FirewallPolicyInner&gt; object wrapped in {@link ServiceResponse} if successful.
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> 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.");
        }
        final String apiVersion = "2019-11-01";
        return service.listByResourceGroup(resourceGroupName, this.client.subscriptionId(), apiVersion, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<PageImpl<FirewallPolicyInner>> result = listByResourceGroupDelegate(response);
                        return Observable.just(new ServiceResponse<Page<FirewallPolicyInner>>(result.body(), result.response()));
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<PageImpl<FirewallPolicyInner>> listByResourceGroupDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<PageImpl<FirewallPolicyInner>, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<PageImpl<FirewallPolicyInner>>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Gets all the Firewall Policies in a subscription.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the PagedList<FirewallPolicyInner> object if successful./**
     * Gets all the Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object if successful.
     */
    public PagedList<FirewallPolicyInner> list() {
        ServiceResponse<Page<FirewallPolicyInner>> response = listSinglePageAsync().toBlocking().single();
        return new PagedList<FirewallPolicyInner>(response.body()) {
            @Override
            public Page<FirewallPolicyInner> nextPage(String nextPageLink) {
                return listNextSinglePageAsync(nextPageLink).toBlocking().single().body();
            }
        };
    }

    Gets all the Firewall Policies in a subscription.
Params: serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Gets all the Firewall Policies in a 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<List<FirewallPolicyInner>> listAsync(final ListOperationCallback<FirewallPolicyInner> serviceCallback) {
        return AzureServiceFuture.fromPageResponse(
            listSinglePageAsync(),
            new Func1<String, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(String nextPageLink) {
                    return listNextSinglePageAsync(nextPageLink);
                }
            },
            serviceCallback);
    }

    Gets all the Firewall Policies in a subscription.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Gets all the Firewall Policies in a subscription.
     *
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the PagedList&lt;FirewallPolicyInner&gt; object
     */
    public Observable<Page<FirewallPolicyInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Page<FirewallPolicyInner>>() {
                @Override
                public Page<FirewallPolicyInner> call(ServiceResponse<Page<FirewallPolicyInner>> response) {
                    return response.body();
                }
            });
    }

    Gets all the Firewall Policies in a subscription.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Gets all the Firewall Policies in a subscription.
     *
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the observable to the PagedList&lt;FirewallPolicyInner&gt; object
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listWithServiceResponseAsync() {
        return listSinglePageAsync()
            .concatMap(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(ServiceResponse<Page<FirewallPolicyInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }

    Gets all the Firewall Policies in a subscription.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the PagedList<FirewallPolicyInner> object wrapped in ServiceResponse if successful./**
     * Gets all the Firewall Policies in a subscription.
     *
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the PagedList&lt;FirewallPolicyInner&gt; object wrapped in {@link ServiceResponse} if successful.
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listSinglePageAsync() {
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2019-11-01";
        return service.list(this.client.subscriptionId(), apiVersion, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<PageImpl<FirewallPolicyInner>> result = listDelegate(response);
                        return Observable.just(new ServiceResponse<Page<FirewallPolicyInner>>(result.body(), result.response()));
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<PageImpl<FirewallPolicyInner>> listDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<PageImpl<FirewallPolicyInner>, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<PageImpl<FirewallPolicyInner>>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Lists all Firewall Policies in a resource group.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the PagedList<FirewallPolicyInner> object if successful./**
     * Lists all Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object if successful.
     */
    public PagedList<FirewallPolicyInner> listByResourceGroupNext(final String nextPageLink) {
        ServiceResponse<Page<FirewallPolicyInner>> response = listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single();
        return new PagedList<FirewallPolicyInner>(response.body()) {
            @Override
            public Page<FirewallPolicyInner> nextPage(String nextPageLink) {
                return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body();
            }
        };
    }

    Lists all Firewall Policies in a resource group.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
serviceFuture – the ServiceFuture object tracking the Retrofit calls
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Lists all Firewall Policies in a 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<List<FirewallPolicyInner>> listByResourceGroupNextAsync(final String nextPageLink, final ServiceFuture<List<FirewallPolicyInner>> serviceFuture, final ListOperationCallback<FirewallPolicyInner> serviceCallback) {
        return AzureServiceFuture.fromPageResponse(
            listByResourceGroupNextSinglePageAsync(nextPageLink),
            new Func1<String, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(String nextPageLink) {
                    return listByResourceGroupNextSinglePageAsync(nextPageLink);
                }
            },
            serviceCallback);
    }

    Lists all Firewall Policies in a resource group.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Lists all Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object
     */
    public Observable<Page<FirewallPolicyInner>> listByResourceGroupNextAsync(final String nextPageLink) {
        return listByResourceGroupNextWithServiceResponseAsync(nextPageLink)
            .map(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Page<FirewallPolicyInner>>() {
                @Override
                public Page<FirewallPolicyInner> call(ServiceResponse<Page<FirewallPolicyInner>> response) {
                    return response.body();
                }
            });
    }

    Lists all Firewall Policies in a resource group.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Lists all Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listByResourceGroupNextWithServiceResponseAsync(final String nextPageLink) {
        return listByResourceGroupNextSinglePageAsync(nextPageLink)
            .concatMap(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(ServiceResponse<Page<FirewallPolicyInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }

    Lists all Firewall Policies in a resource group.
ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the PagedList<FirewallPolicyInner> object wrapped in ServiceResponse if successful./**
     * Lists all Firewall Policies in a resource group.
     *
    ServiceResponse<PageImpl<FirewallPolicyInner>> * @param nextPageLink The NextLink from the previous successful call to List operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the PagedList&lt;FirewallPolicyInner&gt; object wrapped in {@link ServiceResponse} if successful.
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> 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<Response<ResponseBody>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<PageImpl<FirewallPolicyInner>> result = listByResourceGroupNextDelegate(response);
                        return Observable.just(new ServiceResponse<Page<FirewallPolicyInner>>(result.body(), result.response()));
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<PageImpl<FirewallPolicyInner>> listByResourceGroupNextDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<PageImpl<FirewallPolicyInner>, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<PageImpl<FirewallPolicyInner>>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

    Gets all the Firewall Policies in a subscription.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
CloudException – thrown if the request is rejected by server
RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns: the PagedList<FirewallPolicyInner> object if successful./**
     * Gets all the Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object if successful.
     */
    public PagedList<FirewallPolicyInner> listNext(final String nextPageLink) {
        ServiceResponse<Page<FirewallPolicyInner>> response = listNextSinglePageAsync(nextPageLink).toBlocking().single();
        return new PagedList<FirewallPolicyInner>(response.body()) {
            @Override
            public Page<FirewallPolicyInner> nextPage(String nextPageLink) {
                return listNextSinglePageAsync(nextPageLink).toBlocking().single().body();
            }
        };
    }

    Gets all the Firewall Policies in a subscription.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
serviceFuture – the ServiceFuture object tracking the Retrofit calls
serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the ServiceFuture object/**
     * Gets all the Firewall Policies in a 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<List<FirewallPolicyInner>> listNextAsync(final String nextPageLink, final ServiceFuture<List<FirewallPolicyInner>> serviceFuture, final ListOperationCallback<FirewallPolicyInner> serviceCallback) {
        return AzureServiceFuture.fromPageResponse(
            listNextSinglePageAsync(nextPageLink),
            new Func1<String, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(String nextPageLink) {
                    return listNextSinglePageAsync(nextPageLink);
                }
            },
            serviceCallback);
    }

    Gets all the Firewall Policies in a subscription.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Gets all the Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object
     */
    public Observable<Page<FirewallPolicyInner>> listNextAsync(final String nextPageLink) {
        return listNextWithServiceResponseAsync(nextPageLink)
            .map(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Page<FirewallPolicyInner>>() {
                @Override
                public Page<FirewallPolicyInner> call(ServiceResponse<Page<FirewallPolicyInner>> response) {
                    return response.body();
                }
            });
    }

    Gets all the Firewall Policies in a subscription.
Params: nextPageLink – The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the observable to the PagedList<FirewallPolicyInner> object/**
     * Gets all the Firewall Policies in a 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&lt;FirewallPolicyInner&gt; object
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listNextWithServiceResponseAsync(final String nextPageLink) {
        return listNextSinglePageAsync(nextPageLink)
            .concatMap(new Func1<ServiceResponse<Page<FirewallPolicyInner>>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(ServiceResponse<Page<FirewallPolicyInner>> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
                }
            });
    }

    Gets all the Firewall Policies in a subscription.
ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation.
Throws: IllegalArgumentException – thrown if parameters fail the validation
Returns: the PagedList<FirewallPolicyInner> object wrapped in ServiceResponse if successful./**
     * Gets all the Firewall Policies in a subscription.
     *
    ServiceResponse<PageImpl<FirewallPolicyInner>> * @param nextPageLink The NextLink from the previous successful call to List operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation
     * @return the PagedList&lt;FirewallPolicyInner&gt; object wrapped in {@link ServiceResponse} if successful.
     */
    public Observable<ServiceResponse<Page<FirewallPolicyInner>>> listNextSinglePageAsync(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.listNext(nextUrl, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Page<FirewallPolicyInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<FirewallPolicyInner>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<PageImpl<FirewallPolicyInner>> result = listNextDelegate(response);
                        return Observable.just(new ServiceResponse<Page<FirewallPolicyInner>>(result.body(), result.response()));
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }

    private ServiceResponse<PageImpl<FirewallPolicyInner>> listNextDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
        return this.client.restClient().responseBuilderFactory().<PageImpl<FirewallPolicyInner>, CloudException>newInstance(this.client.serializerAdapter())
                .register(200, new TypeToken<PageImpl<FirewallPolicyInner>>() { }.getType())
                .registerError(CloudException.class)
                .build(response);
    }

}
Params:	resourceGroupName – The name of the resource group. firewallPolicyName – The name of the Firewall Policy.
Throws:	IllegalArgumentException – thrown if parameters fail the validation CloudException – thrown if the request is rejected by server RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Throws:	IllegalArgumentException – thrown if parameters fail the validation
Returns:	the PagedList<FirewallPolicyInner> object wrapped in `ServiceResponse` if successful.
Params:	serviceCallback – the async ServiceCallback to handle successful and failed responses.
Throws:	IllegalArgumentException – thrown if parameters fail the validation
Returns:	the `ServiceFuture` object
Params:	nextPageLink – The NextLink from the previous successful call to List operation.
Throws:	IllegalArgumentException – thrown if parameters fail the validation CloudException – thrown if the request is rejected by server RuntimeException – all other wrapped checked exceptions if the request fails to be sent
Returns:	the PagedList<FirewallPolicyInner> object if successful.
/

com.microsoft.azure/ azure-mgmt-network/ 1.41.0/ com/microsoft/azure/management/network/implementation/FirewallPoliciesInner.java
