ContinuablePagedFlux<C,T,P> Class
- java.
lang. Object - reactor.
core. publisher. Flux - com.
azure. core. util. paging. ContinuablePagedFlux<C,T,P>
- com.
- reactor.
Type Parameters
- C
Type of the continuation token.
- T
Type of the elements in the page.
- P
Type of the page.
public abstract class ContinuablePagedFlux<C,T,P>
extends Flux<T>
This class is a Flux implementation that provides the ability to operate on pages of type ContinuablePage<C,T> and individual items in such pages. This type supports user-provided continuation tokens, allowing for restarting from a previously-retrieved continuation token.
Constructor Summary
Modifier | Constructor | Description |
---|---|---|
ContinuablePagedFlux() |
Creates an instance of Continuable |
|
protected | ContinuablePagedFlux(Predicate<C> continuationPredicate) |
Creates an instance of Continuable |
Method Summary
Modifier and Type | Method and Description |
---|---|
abstract Flux<P> |
byPage()
Gets a Flux of ContinuablePage<C,T> starting at the first page. |
abstract Flux<P> |
byPage(C continuationToken)
Gets a Flux of ContinuablePage<C,T> beginning at the page identified by the given continuation token. |
abstract Flux<P> |
byPage(C continuationToken, int preferredPageSize)
Gets a Flux of ContinuablePage<C,T> beginning at the page identified by the given continuation token requesting each page to contain the number of elements equal to the preferred page size. |
abstract Flux<P> |
byPage(int preferredPageSize)
Gets a Flux of ContinuablePage<C,T> starting at the first page requesting each page to contain a number of elements equal to the preferred page size. |
protected final Predicate<C> |
getContinuationPredicate()
Gets the Predicate that determines if paging should continue. |
Methods inherited from java.lang.Object
Methods inherited from reactor.core.publisher.Flux
Constructor Details
ContinuablePagedFlux
public ContinuablePagedFlux()
Creates an instance of ContinuablePagedFlux.
Continuation completes when the last returned continuation token is null.
ContinuablePagedFlux
protected ContinuablePagedFlux(Predicate
Creates an instance of ContinuablePagedFlux.
If continuationPredicate
is null then the predicate will only check if the continuation token is non-null.
Parameters:
Method Details
byPage
public abstract Flux
byPage()
Gets a Flux of ContinuablePage<C,T> starting at the first page.
Returns:
byPage
public abstract Flux
byPage(C continuationToken)
Gets a Flux of ContinuablePage<C,T> beginning at the page identified by the given continuation token.
Parameters:
Returns:
byPage
public abstract Flux
byPage(C continuationToken, int preferredPageSize)
Gets a Flux of ContinuablePage<C,T> beginning at the page identified by the given continuation token requesting each page to contain the number of elements equal to the preferred page size.
The service may or may not honor the preferred page size therefore the client MUST be prepared to handle pages with different page sizes.
Parameters:
Returns:
byPage
public abstract Flux
byPage(int preferredPageSize)
Gets a Flux of ContinuablePage<C,T> starting at the first page requesting each page to contain a number of elements equal to the preferred page size.
The service may or may not honor the preferred page size therefore the client MUST be prepared to handle pages with different page sizes.
Parameters:
Returns:
getContinuationPredicate
protected final Predicate
Gets the Predicate that determines if paging should continue.
Returns:
Applies to
Azure SDK for Java