CosmosPagedIterable<T> Class

Package:

com.azure.cosmos.util

Maven Artifact:

com.azure:azure-cosmos:4.63.4

• java.lang.Object
• • com.azure.core.util.IterableStream<T>
  • • com.azure.core.util.paging.ContinuablePagedIterable<C,T,P>
    • • com.azure.cosmos.util.CosmosPagedIterable<T>

Type Parameters

T

The type of elements in a ContinuablePage<C,T>

public final class CosmosPagedIterable
extends ContinuablePagedIterable<String,T,FeedResponse<T>>

Cosmos implementation of ContinuablePagedIterable<C,T,P>.

This type is a IterableStream<T> that provides the ability to operate on pages of type FeedResponse<T> 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<C,T,P>

Constructor Summary

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

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 IterableStream

<T>of

Methods inherited from ContinuablePagedIterable

iterableByPage iterableByPage iterableByPage iterableByPage iterator stream streamByPage streamByPage streamByPage streamByPage

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

CosmosPagedIterable

public CosmosPagedIterable(CosmosPagedFlux cosmosPagedFlux)

Creates instance given CosmosPagedFlux<T>.

Parameters:

cosmosPagedFlux - the paged flux use as iterable

CosmosPagedIterable

public CosmosPagedIterable(CosmosPagedFlux cosmosPagedFlux, int pageSize)

Creates instance given CosmosPagedFlux<T>.

Parameters:

cosmosPagedFlux - the paged flux use as iterable

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

CosmosPagedIterable

public CosmosPagedIterable(CosmosPagedFlux cosmosPagedFlux, int pageSize, int pagePrefetchCount)

Creates instance given CosmosPagedFlux<T>.

Parameters:

cosmosPagedFlux - the paged flux use as iterable

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

pagePrefetchCount - the number of pages prefetched from the paged flux - note that this might be interpolated by Reactor - for example all numbers > 1 but < 8 will result in at least prefetching 8 pages. See reactor.util.concurrent.Queues.get(int) for more details

Method Details

handle

public CosmosPagedIterable handle(Consumer> feedResponseConsumer)

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

Parameters:

feedResponseConsumer - handler

Returns:

CosmosPagedIterable instance with attached handler