Package com.azure.storage.blob.changefeed

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 of ContinuablePagedFlux for Changefeed where the continuation token type is String, the element type is BlobChangefeedEvent, and the page type is BlobChangefeedPagedResponse.

Method Summary

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 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)

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

byPage

public Flux<BlobChangefeedPagedResponse> byPage()

Specified by:

byPage in class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

byPage

public Flux<BlobChangefeedPagedResponse> byPage(String continuationToken)

Unsupported. To resume with the continuation token, call BlobChangefeedAsyncClient.getEvents(String) or BlobChangefeedClient.getEvents(String).

Specified by:

byPage in class com.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 class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

byPage

public 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.

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 class com.azure.core.util.paging.ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

Parameters:

continuationToken - Unsupported. To resume with the continuation token, call BlobChangefeedAsyncClient.getEvents(String) or BlobChangefeedClient.getEvents(String).

preferredPageSize - The preferred page size.

Returns:

A Flux of ContinuablePage.

Throws:

UnsupportedOperationException - if a continuation token is specified.

subscribe

public void subscribe(CoreSubscriber<? super BlobChangefeedEvent> coreSubscriber)

Specified by:

subscribe in interface CorePublisher<BlobChangefeedEvent>

Specified by:

subscribe in class Flux<BlobChangefeedEvent>