CosmosPagedFlux<T> Class
- java.
lang. Object - reactor.
core. publisher. Flux - com.
azure. core. util. paging. ContinuablePagedFlux<C,T,P> - com.
azure. cosmos. util. CosmosPagedFlux<T>
- com.
- com.
- reactor.
Type Parameters
- T
The type of elements in a ContinuablePage<C,T>
public final class CosmosPagedFlux
extends ContinuablePagedFlux<String,T,FeedResponse<T>>
Cosmos implementation of ContinuablePagedFlux<C,T,P>.
This type is a Flux 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 ContinuablePagedFlux<C,T,P>
Method Summary
Modifier and Type | Method and Description |
---|---|
Flux<Feed |
byPage() |
Flux<Feed |
byPage(int preferredPageSize) |
Flux<Feed |
byPage(String continuationToken) |
Flux<Feed |
byPage(String continuationToken, int preferredPageSize) |
Cosmos |
handle(Consumer<FeedResponse<T>> newFeedResponseConsumer)
Handle for invoking "side-effects" on each Feed |
void |
subscribe(CoreSubscriber<? super T> coreSubscriber)
Subscribe to consume all items of type |
Methods inherited from ContinuablePagedFlux
Methods inherited from java.lang.Object
Methods inherited from reactor.core.publisher.Flux
Method Details
byPage
public Flux<>
Overrides:
CosmosPagedFlux<T>.byPage()byPage
public Flux<>
Overrides:
CosmosPagedFlux<T>.byPage(int preferredPageSize)Parameters:
byPage
public Flux<>
Overrides:
CosmosPagedFlux<T>.byPage(String continuationToken)Parameters:
byPage
public Flux<>
Overrides:
CosmosPagedFlux<T>.byPage(String continuationToken, int preferredPageSize)Parameters:
handle
public CosmosPagedFlux
Handle for invoking "side-effects" on each FeedResponse returned by CosmosPagedFlux
Parameters:
Returns:
subscribe
public void subscribe(CoreSubscriber super T> coreSubscriber)
Subscribe to consume all items of type T
in the sequence respectively. This is recommended for most common scenarios. This will seamlessly fetch next page when required and provide with a Flux of items.
Overrides:
CosmosPagedFlux<T>.subscribe(CoreSubscriber<? super T> coreSubscriber)Parameters:
Applies to
Azure SDK for Java
Commentaires
https://aka.ms/ContentUserFeedback.
Bientôt disponible : Tout au long de 2024, nous allons supprimer progressivement GitHub Issues comme mécanisme de commentaires pour le contenu et le remplacer par un nouveau système de commentaires. Pour plus d’informations, consultezEnvoyer et afficher des commentaires pour