public final class CFBackedPageAsyncStream<T>
extends java.lang.Object
implements com.azure.android.core.util.AsyncStream<com.azure.android.core.rest.util.paging.PagedResponse<T>>
Constructor and Description |
---|
CFBackedPageAsyncStream(com.azure.android.core.util.Function<java.lang.String,java9.util.concurrent.CompletableFuture<com.azure.android.core.rest.util.paging.PagedResponse<T>>> pageRetriever,
com.azure.android.core.util.Predicate<java.lang.String> continuationPredicate,
java.lang.String startPageId,
com.azure.android.core.logging.ClientLogger logger) |
Modifier and Type | Method and Description |
---|---|
com.azure.android.core.util.CancellationToken |
forEach(com.azure.android.core.util.AsyncStreamHandler<com.azure.android.core.rest.util.paging.PagedResponse<T>> handler) |
public CFBackedPageAsyncStream(com.azure.android.core.util.Function<java.lang.String,java9.util.concurrent.CompletableFuture<com.azure.android.core.rest.util.paging.PagedResponse<T>>> pageRetriever, com.azure.android.core.util.Predicate<java.lang.String> continuationPredicate, java.lang.String startPageId, com.azure.android.core.logging.ClientLogger logger)
public com.azure.android.core.util.CancellationToken forEach(com.azure.android.core.util.AsyncStreamHandler<com.azure.android.core.rest.util.paging.PagedResponse<T>> handler)
forEach
in interface com.azure.android.core.util.AsyncStream<com.azure.android.core.rest.util.paging.PagedResponse<T>>