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
피드백
https://aka.ms/ContentUserFeedback
출시 예정: 2024년 내내 콘텐츠에 대한 피드백 메커니즘으로 GitHub 문제를 단계적으로 폐지하고 이를 새로운 피드백 시스템으로 바꿀 예정입니다. 자세한 내용은 다음을 참조하세요.다음에 대한 사용자 의견 제출 및 보기