com.microsoft.azure

Class AzureServiceFuture<T>

java.lang.Object

com.google.common.util.concurrent.AbstractFuture<T>

com.microsoft.rest.ServiceFuture<T>

com.microsoft.azure.AzureServiceFuture<T>

Type Parameters:

T - the type of the returning object

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<T>, Future<T>

public final class AzureServiceFuture<T>
extends ServiceFuture<T>

An instance of this class provides access to the underlying REST call invocation. This class wraps around the Retrofit Call object and allows updates to it in the progress of a long running operation or a paging operation.

Method Summary

Modifier and Type	Method and Description
static <E,V> ServiceFuture<List<E>>	fromHeaderPageResponse(rx.Observable<ServiceResponseWithHeaders<Page<E>,V>> first, rx.functions.Func1<String,rx.Observable<ServiceResponseWithHeaders<Page<E>,V>>> next, ListOperationCallback<E> callback) Creates a ServiceCall from a paging operation that returns a header response.
static <E> ServiceFuture<List<E>>	fromPageResponse(rx.Observable<ServiceResponse<Page<E>>> first, rx.functions.Func1<String,rx.Observable<ServiceResponse<Page<E>>>> next, ListOperationCallback<E> callback) Creates a ServiceCall from a paging operation.

Methods inherited from class com.microsoft.rest.ServiceFuture

cancel, fromBody, fromBody, fromHeaderResponse, fromResponse, fromResponse, getSubscription, isCancelled, setSubscription, success

Methods inherited from class com.google.common.util.concurrent.AbstractFuture

addListener, afterDone, get, get, interruptTask, isDone, set, setException, setFuture, wasInterrupted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fromPageResponse

public static <E> ServiceFuture<List<E>> fromPageResponse(rx.Observable<ServiceResponse<Page<E>>> first,
                                                          rx.functions.Func1<String,rx.Observable<ServiceResponse<Page<E>>>> next,
                                                          ListOperationCallback<E> callback)

Creates a ServiceCall from a paging operation.

Type Parameters:

E - the element type

Parameters:

first - the observable to the first page

next - the observable to poll subsequent pages

callback - the client-side callback

Returns:

the future based ServiceCall

fromHeaderPageResponse

public static <E,V> ServiceFuture<List<E>> fromHeaderPageResponse(rx.Observable<ServiceResponseWithHeaders<Page<E>,V>> first,
                                                                  rx.functions.Func1<String,rx.Observable<ServiceResponseWithHeaders<Page<E>,V>>> next,
                                                                  ListOperationCallback<E> callback)

Creates a ServiceCall from a paging operation that returns a header response.

Type Parameters:

E - the element type

V - the header object type

Parameters:

first - the observable to the first page

next - the observable to poll subsequent pages

callback - the client-side callback

Returns:

the future based ServiceCall