com.azure.cosmos

Class ContinuablePagedIterable<C,T,P extends com.azure.core.util.paging.ContinuablePage<C,T>>

java.lang.Object

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

com.azure.cosmos.ContinuablePagedIterable<C,T,P>

Type Parameters:

C - the type of the continuation token

T - The type of elements in a ContinuablePage

P - The ContinuablePage holding items of type T.

All Implemented Interfaces:

Iterable<T>

Direct Known Subclasses:

CosmosContinuablePagedIterable

public abstract class ContinuablePagedIterable<C,T,P extends com.azure.core.util.paging.ContinuablePage<C,T>>
extends com.azure.core.util.IterableStream<T>

This class provides utility to iterate over ContinuablePage using Stream Iterable interfaces.

See Also:

IterableStream, ContinuablePagedFlux

Constructor Summary

Constructors

Constructor and Description
ContinuablePagedIterable(com.azure.core.util.paging.ContinuablePagedFlux<C,T,P> pagedFlux) Creates instance given ContinuablePagedFlux.
ContinuablePagedIterable(com.azure.core.util.paging.ContinuablePagedFlux<C,T,P> pagedFlux, int batchSize) Creates instance given ContinuablePagedFlux.

Method Summary

Modifier and Type	Method and Description
Iterable<P>	iterableByPage() Retrieve the Iterable, one page at a time.
Iterable<P>	iterableByPage(C continuationToken) Retrieve the Iterable, one page at a time, starting from the next page associated with the given continuation token.
Iterable<P>	iterableByPage(C continuationToken, int preferredPageSize) Retrieve the Iterable, one page at a time, with each page containing preferredPageSize items, starting from the next page associated with the given continuation token.
Iterable<P>	iterableByPage(int preferredPageSize) Retrieve the Iterable, one page at a time, with each page containing preferredPageSize items.
Stream<P>	streamByPage() Retrieve the Stream, one page at a time.
Stream<P>	streamByPage(C continuationToken) Retrieve the Stream, one page at a time, starting from the next page associated with the given continuation token.
Stream<P>	streamByPage(C continuationToken, int preferredPageSize) Retrieve the Stream, one page at a time, with each page containing preferredPageSize items, starting from the next page associated with the given continuation token.
Stream<P>	streamByPage(int preferredPageSize) Retrieve the Stream, one page at a time, with each page containing preferredPageSize items.

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

iterator, of, stream

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

ContinuablePagedIterable

public ContinuablePagedIterable(com.azure.core.util.paging.ContinuablePagedFlux<C,T,P> pagedFlux)

Creates instance given ContinuablePagedFlux.

Parameters:

pagedFlux - the paged flux use as iterable

ContinuablePagedIterable

public ContinuablePagedIterable(com.azure.core.util.paging.ContinuablePagedFlux<C,T,P> pagedFlux,
                                int batchSize)

Creates instance given ContinuablePagedFlux.

Parameters:

pagedFlux - the paged flux use as iterable

Method Detail

streamByPage

public Stream<P> streamByPage()

Retrieve the Stream, one page at a time. It will provide same Stream of T values from starting if called multiple times.

Returns:

Stream of a pages

streamByPage

public Stream<P> streamByPage(C continuationToken)

Retrieve the Stream, one page at a time, starting from the next page associated with the given continuation token. To start from first page, use streamByPage() instead.

Parameters:

continuationToken - The continuation token used to fetch the next page

Returns:

@return Stream of a pages

streamByPage

public Stream<P> streamByPage(int preferredPageSize)

Retrieve the Stream, one page at a time, with each page containing preferredPageSize items. It will provide same Stream of T values from starting if called multiple times.

Parameters:

preferredPageSize - the preferred page size, service may or may not honor the page size preference hence client MUST be prepared to handle pages with different page size.

Returns:

@return Stream of a pages

streamByPage

public Stream<P> streamByPage(C continuationToken,
                              int preferredPageSize)

Retrieve the Stream, one page at a time, with each page containing preferredPageSize items, starting from the next page associated with the given continuation token. To start from first page, use streamByPage() or streamByPage(int) instead.

Parameters:

preferredPageSize - the preferred page size, service may or may not honor the page size preference hence client MUST be prepared to handle pages with different page size.

continuationToken - The continuation token used to fetch the next page

Returns:

@return Stream of a pages

iterableByPage

public Iterable<P> iterableByPage()

Retrieve the Iterable, one page at a time. It will provide same Iterable of T values from starting if called multiple times.

Returns:

Stream of a pages

iterableByPage

public Iterable<P> iterableByPage(C continuationToken)

Retrieve the Iterable, one page at a time, starting from the next page associated with the given continuation token. To start from first page, use iterableByPage() instead.

Parameters:

continuationToken - The continuation token used to fetch the next page

Returns:

@return Iterable of a pages

iterableByPage

public Iterable<P> iterableByPage(int preferredPageSize)

Retrieve the Iterable, one page at a time, with each page containing preferredPageSize items. It will provide same Iterable of T values from starting if called multiple times.

Parameters:

preferredPageSize - the preferred page size, service may or may not honor the page size preference hence client MUST be prepared to handle pages with different page size.

Returns:

@return Iterable of a pages

iterableByPage

public Iterable<P> iterableByPage(C continuationToken,
                                  int preferredPageSize)

Retrieve the Iterable, one page at a time, with each page containing preferredPageSize items, starting from the next page associated with the given continuation token. To start from first page, use iterableByPage() or iterableByPage(int) instead.

Parameters:

preferredPageSize - the preferred page size, service may or may not honor the page size preference hence client MUST be prepared to handle pages with different page size.

continuationToken - The continuation token used to fetch the next page

Returns:

@return Iterable of a pages