CosmosPagedIterable<T> Class
- java.
lang. Object - com.
azure. core. util. IterableStream<T> - com.
azure. core. util. paging. ContinuablePagedIterable<C,T,P> - com.
azure. cosmos. util. CosmosPagedIterable<T>
- com.
- com.
- com.
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 |
---|---|
Cosmos |
handle(Consumer<FeedResponse<T>> feedResponseConsumer)
Handle for invoking "side-effects" on each Feed |
Methods inherited from IterableStream
Methods inherited from ContinuablePagedIterable
Methods inherited from java.lang.Object
Constructor Details
CosmosPagedIterable
public CosmosPagedIterable(CosmosPagedFlux
Creates instance given CosmosPagedFlux<T>.
Parameters:
CosmosPagedIterable
public CosmosPagedIterable(CosmosPagedFlux
Creates instance given CosmosPagedFlux<T>.
Parameters:
CosmosPagedIterable
public CosmosPagedIterable(CosmosPagedFlux
Creates instance given CosmosPagedFlux<T>.
Parameters:
reactor.util.concurrent.Queues.get(int)
for more details
Method Details
handle
public CosmosPagedIterable
Handle for invoking "side-effects" on each FeedResponse returned by CosmosPagedIterable
Parameters:
Returns: