Class BlobChangefeedPagedFlux
- java.lang.Object
-
- reactor.core.publisher.Flux<T>
-
- com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
-
- com.azure.storage.blob.changefeed.BlobChangefeedPagedFlux
-
- All Implemented Interfaces:
org.reactivestreams.Publisher<BlobChangefeedEvent>
,CorePublisher<BlobChangefeedEvent>
public final class BlobChangefeedPagedFlux extends com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
Implementation ofContinuablePagedFlux
for Changefeed where the continuation token type isString
, the element type isBlobChangefeedEvent
, and the page type isBlobChangefeedPagedResponse
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Flux<BlobChangefeedPagedResponse>
byPage()
Flux<BlobChangefeedPagedResponse>
byPage(int preferredPageSize)
Flux<BlobChangefeedPagedResponse>
byPage(String continuationToken)
Unsupported.Flux<BlobChangefeedPagedResponse>
byPage(String continuationToken, int preferredPageSize)
Gets aFlux
ofContinuablePage
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)
-
Methods inherited from class com.azure.core.util.paging.ContinuablePagedFlux
getContinuationPredicate
-
Methods inherited from class reactor.core.publisher.Flux
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, 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, zipWithIterable
-
-
-
-
Method Detail
-
byPage
public Flux<BlobChangefeedPagedResponse> byPage()
- Specified by:
byPage
in classcom.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
-
byPage
public Flux<BlobChangefeedPagedResponse> byPage(String continuationToken)
Unsupported. To resume with the continuation token, callBlobChangefeedAsyncClient.getEvents(String)
orBlobChangefeedClient.getEvents(String)
.- Specified by:
byPage
in classcom.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
- Parameters:
continuationToken
- Unsupported.- Returns:
- Unsupported.
- Throws:
UnsupportedOperationException
- if a continuation token is specified.
-
byPage
public Flux<BlobChangefeedPagedResponse> byPage(int preferredPageSize)
- Specified by:
byPage
in classcom.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
-
byPage
public Flux<BlobChangefeedPagedResponse> byPage(String continuationToken, int preferredPageSize)
Gets aFlux
ofContinuablePage
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.
- Specified by:
byPage
in classcom.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>
- Parameters:
continuationToken
- Unsupported. To resume with the continuation token, callBlobChangefeedAsyncClient.getEvents(String)
orBlobChangefeedClient.getEvents(String)
.preferredPageSize
- The preferred page size.- Returns:
- A
Flux
ofContinuablePage
. - Throws:
UnsupportedOperationException
- if a continuation token is specified.
-
subscribe
public void subscribe(CoreSubscriber<? super BlobChangefeedEvent> coreSubscriber)
- Specified by:
subscribe
in interfaceCorePublisher<BlobChangefeedEvent>
- Specified by:
subscribe
in classFlux<BlobChangefeedEvent>
-
-