@Override
public Mono<ListOrganizationsResponse> retrieveAllOrgIds() {
	PaginatedRequestGeneratorFunction<ListOrganizationsRequest> requestGenerator = (orderDirection, resultsPerPage, pageNumber) ->
		ListOrganizationsRequest.builder()
			.orderDirection(orderDirection)
			.resultsPerPage(resultsPerPage)
			.page(pageNumber)
			.build();
	
	PaginatedResponseGeneratorFunction<OrganizationResource, ListOrganizationsResponse> responseGenerator = (list, numberOfPages) ->
			ListOrganizationsResponse.builder()
			.addAllResources(list)
			.totalPages(numberOfPages)
			.totalResults(list.size())
			.build();
	
	return this.paginatedRequestFetcher.performGenericPagedRetrieval(RequestType.ALL_ORGS, "(empty)", requestGenerator, 
			r -> this.cloudFoundryClient.organizations().list(r),  this.requestTimeoutOrg, responseGenerator);
}
 

@Override
public Mono<ListOrganizationsResponse> retrieveOrgId(String orgName) {
	// Note: even though we use the List request here, the number of values returned is either zero or one
	// ==> No need for a paged request. 
	ListOrganizationsRequest orgsRequest = ListOrganizationsRequest.builder().name(orgName).build();
	
	return this.paginatedRequestFetcher.performGenericRetrieval(RequestType.ORG, orgName, orgsRequest,
			or -> this.cloudFoundryClient.organizations()
			          .list(or), this.requestTimeoutOrg);
}
 

private Mono<? extends Resource<OrganizationEntity>> getOrganizationResourceByName(String name) {
    IntFunction<ListOrganizationsRequest> pageRequestSupplier = page -> ListOrganizationsRequest.builder()
                                                                                                .name(name)
                                                                                                .page(page)
                                                                                                .build();
    return getOrganizationResources(pageRequestSupplier).singleOrEmpty();
}
 

private Mono<String> organizationId() {
	String org = this.runtimeEnvironmentInfo.getPlatformSpecificInfo().get(CloudFoundryPlatformSpecificInfo.ORG);
	Assert.hasText(org,"Missing runtimeEnvironmentInfo : 'org' required.");
	ListOrganizationsRequest listOrganizationsRequest =  ListOrganizationsRequest.builder()
			.name(org).build();
	return this.client.organizations().list(listOrganizationsRequest)
			.doOnError(logError("Failed to list organizations"))
			.map(listOrganizationsResponse -> listOrganizationsResponse.getResources().get(0).getMetadata().getId())
			.cache(aValue -> Duration.ofMillis(Long.MAX_VALUE), aValue -> Duration.ZERO, () -> Duration.ZERO);
}
 

private Flux<? extends Resource<OrganizationEntity>> getOrganizationResources() {
    IntFunction<ListOrganizationsRequest> pageRequestSupplier = page -> ListOrganizationsRequest.builder()
                                                                                                .page(page)
                                                                                                .build();
    return getOrganizationResources(pageRequestSupplier);
}
 

private Flux<? extends Resource<OrganizationEntity>>
        getOrganizationResources(IntFunction<ListOrganizationsRequest> pageRequestSupplier) {
    return PaginationUtils.requestClientV2Resources(page -> delegate.organizations()
                                                                    .list(pageRequestSupplier.apply(page)));
}