T - The type of elements in a ContinuablePagepublic final class CosmosPagedFlux<T> extends com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>
ContinuablePagedFlux.
This type is a Flux that provides the ability to operate on pages of type FeedResponse 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
ContinuablePage,
CosmosPagedFluxOptions,
FeedResponse| Modifier and Type | Method and Description |
|---|---|
Flux<FeedResponse<T>> |
byPage() |
Flux<FeedResponse<T>> |
byPage(int preferredPageSize) |
Flux<FeedResponse<T>> |
byPage(String continuationToken) |
Flux<FeedResponse<T>> |
byPage(String continuationToken,
int preferredPageSize) |
CosmosPagedFlux<T> |
handle(Consumer<FeedResponse<T>> newFeedResponseConsumer)
Handle for invoking "side-effects" on each FeedResponse returned by CosmosPagedFlux
|
void |
subscribe(CoreSubscriber<? super T> coreSubscriber)
Subscribe to consume all items of type
T in the sequence respectively. |
getContinuationPredicateall, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferUntilChanged, bufferUntilChanged, bufferUntilChanged, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, deferWithContext, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, mapNotNull, materialize, merge, merge, merge, merge, merge, merge, mergeComparing, mergeComparing, mergeComparing, mergeComparingDelayError, mergeComparingWith, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, shareNext, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterablepublic CosmosPagedFlux<T> handle(Consumer<FeedResponse<T>> newFeedResponseConsumer)
newFeedResponseConsumer - handlerpublic Flux<FeedResponse<T>> byPage()
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public Flux<FeedResponse<T>> byPage(String continuationToken)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public Flux<FeedResponse<T>> byPage(int preferredPageSize)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public Flux<FeedResponse<T>> byPage(String continuationToken, int preferredPageSize)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public void subscribe(CoreSubscriber<? super T> coreSubscriber)
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.subscribe in interface CorePublisher<T>subscribe in class Flux<T>coreSubscriber - The subscriber for this CosmosPagedFluxCopyright © 2021 Microsoft Corporation. All rights reserved.