T - The type of elements in a ContinuablePagepublic class CosmosContinuablePagedFlux<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 |
|---|---|
reactor.core.publisher.Flux<FeedResponse<T>> |
byPage() |
reactor.core.publisher.Flux<FeedResponse<T>> |
byPage(int preferredPageSize) |
reactor.core.publisher.Flux<FeedResponse<T>> |
byPage(String continuationToken) |
reactor.core.publisher.Flux<FeedResponse<T>> |
byPage(String continuationToken,
int preferredPageSize) |
void |
subscribe(reactor.core.CoreSubscriber<? super T> coreSubscriber)
Subscribe to consume all items of type
T in the sequence respectively. |
all, 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, compose, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, count, create, create, defaultIfEmpty, defer, 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, 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, materialize, merge, merge, merge, merge, merge, merge, 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, onLastAssembly, 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, retry, retry, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, 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, switchOnNext, switchOnNext, tag, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, using, using, usingWhen, usingWhen, 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 reactor.core.publisher.Flux<FeedResponse<T>> byPage()
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public reactor.core.publisher.Flux<FeedResponse<T>> byPage(String continuationToken)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public reactor.core.publisher.Flux<FeedResponse<T>> byPage(int preferredPageSize)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public reactor.core.publisher.Flux<FeedResponse<T>> byPage(String continuationToken, int preferredPageSize)
byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,T,FeedResponse<T>>public void subscribe(reactor.core.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 reactor.core.CorePublisher<T>subscribe in class reactor.core.publisher.Flux<T>coreSubscriber - The subscriber for this CosmosContinuablePagedFluxCopyright © 2020 Microsoft Corporation. All rights reserved.