public final class BlobChangefeedPagedFlux extends com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
ContinuablePagedFlux
for Changefeed where the continuation token type is String
,
the element type is BlobChangefeedEvent
, and the page type is BlobChangefeedPagedResponse
.Modifier and Type | Method and Description |
---|---|
Flux<BlobChangefeedPagedResponse> |
byPage() |
Flux<BlobChangefeedPagedResponse> |
byPage(int preferredPageSize) |
Flux<BlobChangefeedPagedResponse> |
byPage(String continuationToken)
Unsupported.
|
Flux<BlobChangefeedPagedResponse> |
byPage(String continuationToken,
int preferredPageSize)
Gets a
Flux of ContinuablePage beginning at the page identified by the Changefeed
requesting each page to contain the number of elements equal to the preferred page size. |
void |
subscribe(CoreSubscriber<? super BlobChangefeedEvent> coreSubscriber) |
getContinuationPredicate
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, 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, 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, zipWithIterable
public Flux<BlobChangefeedPagedResponse> byPage()
byPage
in class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
public Flux<BlobChangefeedPagedResponse> byPage(String continuationToken)
BlobChangefeedAsyncClient.getEvents(String)
or
BlobChangefeedClient.getEvents(String)
.byPage
in class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
continuationToken
- Unsupported.UnsupportedOperationException
- if a continuation token is specified.public Flux<BlobChangefeedPagedResponse> byPage(int preferredPageSize)
byPage
in class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
public Flux<BlobChangefeedPagedResponse> byPage(String continuationToken, int preferredPageSize)
Flux
of ContinuablePage
beginning at the page identified by the Changefeed
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.
byPage
in class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
continuationToken
- Unsupported. To resume with the continuation token, call
BlobChangefeedAsyncClient.getEvents(String)
or BlobChangefeedClient.getEvents(String)
.preferredPageSize
- The preferred page size.Flux
of ContinuablePage
.UnsupportedOperationException
- if a continuation token is specified.public void subscribe(CoreSubscriber<? super BlobChangefeedEvent> coreSubscriber)
subscribe
in interface CorePublisher<BlobChangefeedEvent>
subscribe
in class Flux<BlobChangefeedEvent>
Copyright © 2021 Microsoft Corporation. All rights reserved.