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 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()	Gets a Flux of ContinuablePage starting at the first page.
Flux<BlobChangefeedPagedResponse>	byPage(int preferredPageSize)	Gets a Flux of ContinuablePage starting at the first page requesting each page to contain a number of elements equal to the preferred page size.
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, 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 Details

byPage

public Flux<BlobChangefeedPagedResponse> byPage()

Description copied from class: ContinuablePagedFlux

Gets a Flux of ContinuablePage starting at the first page.

Specified by:

byPage in class ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

Returns:

A Flux of ContinuablePage.

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 ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

Parameters:

continuationToken - Unsupported.

Returns:

Unsupported.

Throws:

UnsupportedOperationException - if a continuation token is specified.

byPage

public Flux<BlobChangefeedPagedResponse> byPage(int preferredPageSize)

Description copied from class: ContinuablePagedFlux

Gets a Flux of ContinuablePage starting at the first page requesting each page to contain a 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 ContinuablePagedFlux<String,BlobChangefeedEvent,BlobChangefeedPagedResponse>

Parameters:

preferredPageSize - The preferred page size.

Returns:

A Flux of ContinuablePage.

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