com.azure.cosmos.util

Class CosmosPagedIterable<T>

java.lang.Object

com.azure.core.util.IterableStream<T>

com.azure.core.util.paging.ContinuablePagedIterable<String,T,FeedResponse<T>>

com.azure.cosmos.util.CosmosPagedIterable<T>

Type Parameters:

T - The type of elements in a ContinuablePage

All Implemented Interfaces:

Iterable<T>

public final class CosmosPagedIterable<T>
extends com.azure.core.util.paging.ContinuablePagedIterable<String,T,FeedResponse<T>>

Cosmos implementation of ContinuablePagedIterable.

This type is a IterableStream that provides the ability to operate on pages of type FeedResponse and individual items in such pages. This type supports String type continuation tokens, allowing for restarting from a previously-retrieved continuation token.

For more information on the base type, refer ContinuablePagedIterable

See Also:

ContinuablePage, FeedResponse

Constructor Summary

Constructors

Constructor and Description
CosmosPagedIterable(CosmosPagedFlux<T> cosmosPagedFlux) Creates instance given CosmosPagedFlux.
CosmosPagedIterable(CosmosPagedFlux<T> cosmosPagedFlux, int batchSize) Creates instance given CosmosPagedFlux.

Method Summary

Modifier and Type	Method and Description
CosmosPagedIterable<T>	handle(Consumer<FeedResponse<T>> feedResponseConsumer) Handle for invoking "side-effects" on each FeedResponse returned by CosmosPagedIterable

Methods inherited from class com.azure.core.util.paging.ContinuablePagedIterable

iterableByPage, iterableByPage, iterableByPage, iterableByPage, iterator, stream, streamByPage, streamByPage, streamByPage, streamByPage

Methods inherited from class com.azure.core.util.IterableStream

of

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

CosmosPagedIterable

public CosmosPagedIterable(CosmosPagedFlux<T> cosmosPagedFlux)

Creates instance given CosmosPagedFlux.

Parameters:

cosmosPagedFlux - the paged flux use as iterable

CosmosPagedIterable

public CosmosPagedIterable(CosmosPagedFlux<T> cosmosPagedFlux,
                           int batchSize)

Creates instance given CosmosPagedFlux.

Parameters:

cosmosPagedFlux - the paged flux use as iterable

batchSize - the preferred batchSize to be used when pulling data from the service

Method Detail

handle

public CosmosPagedIterable<T> handle(Consumer<FeedResponse<T>> feedResponseConsumer)

Handle for invoking "side-effects" on each FeedResponse returned by CosmosPagedIterable

Parameters:

feedResponseConsumer - handler

Returns:

CosmosPagedIterable instance with attached handler