Converts Observable of page to Observable of Inner.
@param <InnerT> type of inner.
@param innerPage Page to be converted.
@return Observable for list of inner.
551987
public static <InnerT> Observable<InnerT> convertPageToInnerAsync(Observable<Page<InnerT>> innerPage) {
        return innerPage.flatMap(new Func1<Page<InnerT>, Observable<InnerT>>() {
            @Override
            public Observable<InnerT> call(Page<InnerT> pageInner) {
                return Observable.from(pageInner.items());
            }
        });
    }
1284003
public Observable<Page<DatabaseAccountInner>> listAsync() {
        return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<DatabaseAccountInner>>, Page<DatabaseAccountInner>>() {
            @Override
            public Page<DatabaseAccountInner> call(ServiceResponse<List<DatabaseAccountInner>> response) {
                PageImpl<DatabaseAccountInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
1335883
public Observable<Page<CognitiveServicesAccountInner>> listAsync() {
        return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<CognitiveServicesAccountInner>>, Page<CognitiveServicesAccountInner>>() {
            @Override
            public Page<CognitiveServicesAccountInner> call(ServiceResponse<List<CognitiveServicesAccountInner>> response) {
                PageImpl<CognitiveServicesAccountInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
361551
public Observable<Page<AppInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<AppInner>>, Page<AppInner>>() {
                @Override
                public Page<AppInner> call(ServiceResponse<Page<AppInner>> response) {
                    return response.body();
                }
            });
    }
1089583
public Observable<Page<ServerInner>> listAsync() {
        return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ServerInner>>, Page<ServerInner>>() {
            @Override
            public Page<ServerInner> call(ServiceResponse<List<ServerInner>> response) {
                PageImpl<ServerInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
412596
public @Nullable Page getPage(@NotNull Page basePage) {
    return getPage((Predicate<Page>)null, basePage);
  }
248503
public Observable<Page<VpnGatewayInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<VpnGatewayInner>>, Page<VpnGatewayInner>>() {
                @Override
                public Page<VpnGatewayInner> call(ServiceResponse<Page<VpnGatewayInner>> response) {
                    return response.body();
                }
            });
    }
390498
public static <E> ServiceFuture<List<E>> fromPageResponse(Observable<ServiceResponse<Page<E>>> first, final Func1<String, Observable<ServiceResponse<Page<E>>>> next, final ListOperationCallback<E> callback) {
        final AzureServiceFuture<List<E>> serviceCall = new AzureServiceFuture<>();
        final PagingSubscriber<E> subscriber = new PagingSubscriber<>(serviceCall, next, callback);
        serviceCall.setSubscription(first
            .single()
            .subscribe(subscriber));
        return serviceCall;
    }
1037
public Observable<Page<DomainInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<DomainInner>>, Page<DomainInner>>() {
                @Override
                public Page<DomainInner> call(ServiceResponse<Page<DomainInner>> response) {
                    return response.body();
                }
            });
    }
1067332
public Observable<Page<ClientDiscoveryValueForSingleApiInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<ClientDiscoveryValueForSingleApiInner>>, Page<ClientDiscoveryValueForSingleApiInner>>() {
                @Override
                public Page<ClientDiscoveryValueForSingleApiInner> call(ServiceResponse<Page<ClientDiscoveryValueForSingleApiInner>> response) {
                    return response.body();
                }
            });
    }
1071748
public Observable<Page<RegistryInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<RegistryInner>>, Page<RegistryInner>>() {
                @Override
                public Page<RegistryInner> call(ServiceResponse<Page<RegistryInner>> response) {
                    return response.body();
                }
            });
    }
1373716
public Observable<Page<TopicInner>> listByResourceGroupAsync(String resourceGroupName) {
        return listByResourceGroupWithServiceResponseAsync(resourceGroupName).map(new Func1<ServiceResponse<List<TopicInner>>, Page<TopicInner>>() {
            @Override
            public Page<TopicInner> call(ServiceResponse<List<TopicInner>> response) {
                PageImpl<TopicInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
972894
public Observable<Page<ClusterInner>> listByResourceGroupAsync(String resourceGroupName) {
        return listByResourceGroupWithServiceResponseAsync(resourceGroupName).map(new Func1<ServiceResponse<List<ClusterInner>>, Page<ClusterInner>>() {
            @Override
            public Page<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
                PageImpl<ClusterInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
953384
public Observable<ServiceResponseWithHeaders<Page<NodeAgentSku>, AccountListNodeAgentSkusHeaders>> listNodeAgentSkusWithServiceResponseAsync() {
        return listNodeAgentSkusSinglePageAsync()
            .concatMap(new Func1<ServiceResponseWithHeaders<Page<NodeAgentSku>, AccountListNodeAgentSkusHeaders>, Observable<ServiceResponseWithHeaders<Page<NodeAgentSku>, AccountListNodeAgentSkusHeaders>>>() {
                @Override
                public Observable<ServiceResponseWithHeaders<Page<NodeAgentSku>, AccountListNodeAgentSkusHeaders>> call(ServiceResponseWithHeaders<Page<NodeAgentSku>, AccountListNodeAgentSkusHeaders> page) {
                    String nextPageLink = page.body().nextPageLink();
                    if (nextPageLink == null) {
                        return Observable.just(page);
                    }
                    return Observable.just(page).concatWith(listNodeAgentSkusNextWithServiceResponseAsync(nextPageLink, null));
                }
            });
    }
739
public Observable<Page<ResourceSkuInner>> listAsync() {
        return listWithServiceResponseAsync()
            .map(new Func1<ServiceResponse<Page<ResourceSkuInner>>, Page<ResourceSkuInner>>() {
                @Override
                public Page<ResourceSkuInner> call(ServiceResponse<Page<ResourceSkuInner>> response) {
                    return response.body();
                }
            });
    }
1297074
public Observable<Page<TopicInner>> listAsync() {
        return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<TopicInner>>, Page<TopicInner>>() {
            @Override
            public Page<TopicInner> call(ServiceResponse<List<TopicInner>> response) {
                PageImpl<TopicInner> page = new PageImpl<>();
                page.setItems(response.body());
                return page;
            }
        });
    }
740921
public Observable<ServiceResponse<Page<ApplicationGatewayInner>>> listAllSinglePageAsync() {
        if (this.client.subscriptionId() == null) {
            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
        }
        final String apiVersion = "2017-10-01";
        return service.listAll(this.client.subscriptionId(), apiVersion, this.client.acceptLanguage(), this.client.userAgent())
            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Page<ApplicationGatewayInner>>>>() {
                @Override
                public Observable<ServiceResponse<Page<ApplicationGatewayInner>>> call(Response<ResponseBody> response) {
                    try {
                        ServiceResponse<PageImpl<ApplicationGatewayInner>> result = listAllDelegate(response);
                        return Observable.just(new ServiceResponse<Page<ApplicationGatewayInner>>(result.body(), result.response()));
                    } catch (Throwable t) {
                        return Observable.error(t);
                    }
                }
            });
    }