azure-docs-sdk-java/docs-ref-autogen/com.azure.core.util.paging.ContinuablePagedFluxCore.yml

### YamlMime:JavaType
uid: "com.azure.core.util.paging.ContinuablePagedFluxCore"
fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>"
name: "ContinuablePagedFluxCore<C,T,P>"
nameWithType: "ContinuablePagedFluxCore<C,T,P>"
summary: "The default implementation of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFlux\"></xref>."
inheritances:
- "<xref href=\"java.lang.Object?displayProperty=fullName\" data-throw-if-not-resolved=\"False\" />"
- "<xref href=\"reactor.core.publisher.Flux?displayProperty=fullName\" data-throw-if-not-resolved=\"False\" />"
- "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux?displayProperty=fullName\" data-throw-if-not-resolved=\"False\" />"
inheritedClassMethods:
- classRef: "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux?alt=com.azure.core.util.paging.ContinuablePagedFlux&text=ContinuablePagedFlux\" data-throw-if-not-resolved=\"False\" />"
  methodsRef:
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux.byPage()?alt=com.azure.core.util.paging.ContinuablePagedFlux.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux.byPage(C)?alt=com.azure.core.util.paging.ContinuablePagedFlux.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux.byPage(C,int)?alt=com.azure.core.util.paging.ContinuablePagedFlux.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux.byPage(int)?alt=com.azure.core.util.paging.ContinuablePagedFlux.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFlux.getContinuationPredicate()?alt=com.azure.core.util.paging.ContinuablePagedFlux.getContinuationPredicate&text=getContinuationPredicate\" data-throw-if-not-resolved=\"False\" />"
- classRef: "java.lang.<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html\">Object</a>"
  methodsRef:
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#clone--\">clone</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#equals-java.lang.Object-\">equals</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#finalize--\">finalize</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#getClass--\">getClass</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#hashCode--\">hashCode</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notify--\">notify</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notifyAll--\">notifyAll</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait--\">wait</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-\">wait</a>"
  - "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-int-\">wait</a>"
- classRef: "reactor.core.publisher.<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html\">Flux</a>"
  methodsRef:
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#reduce-A-java.util.function.BiFunction-\">reduce</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#reduceWith-java.util.function.Supplier-java.util.function.BiFunction-\">reduceWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#scan-A-java.util.function.BiFunction-\">scan</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#scanWith-java.util.function.Supplier-java.util.function.BiFunction-\">scanWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-int-int-java.util.function.Supplier-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-int-java.util.function.Supplier-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-org.reactivestreams.Publisher-java.util.function.Supplier-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-java.util.function.Supplier-\">bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-reactor.core.scheduler.Scheduler-java.util.function.Supplier-\">bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cast-java.lang.Class-\">cast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collect-java.util.function.Supplier-java.util.function.BiConsumer-\">collect</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnError-java.lang.Class-java.util.function.Consumer-\">doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorContinue-java.lang.Class-java.util.function.BiConsumer-\">onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorContinue-java.util.function.Predicate-java.util.function.BiConsumer-\">onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorMap-java.lang.Class-java.util.function.Function-\">onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorResume-java.lang.Class-java.util.function.Function>-\">onErrorResume</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorReturn-java.lang.Class-T-\">onErrorReturn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribeWith-E-\">subscribeWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-java.util.function.Function-int-org.reactivestreams.Publisher...-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-java.util.function.Function-org.reactivestreams.Publisher...-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#first-java.lang.Iterable>-\">first</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#first-org.reactivestreams.Publisher...-\">first</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#firstWithSignal-java.lang.Iterable>-\">firstWithSignal</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#firstWithSignal-org.reactivestreams.Publisher...-\">firstWithSignal</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#firstWithValue-java.lang.Iterable>-\">firstWithValue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#firstWithValue-org.reactivestreams.Publisher-org.reactivestreams.Publisher...-\">firstWithValue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#index-java.util.function.BiFunction-\">index</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-int-org.reactivestreams.Publisher...-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-java.lang.Iterable>-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-org.reactivestreams.Publisher...-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeComparing-org.reactivestreams.Publisher...-\">mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeDelayError-int-org.reactivestreams.Publisher...-\">mergeDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeOrdered-org.reactivestreams.Publisher...-\">mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergePriority-org.reactivestreams.Publisher...-\">mergePriority</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-int-org.reactivestreams.Publisher...-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-java.lang.Iterable>-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-java.lang.Iterable>-int-int-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-org.reactivestreams.Publisher...-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequentialDelayError-int-org.reactivestreams.Publisher...-\">mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequentialDelayError-java.lang.Iterable>-int-int-\">mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMap-java.util.function.Function-java.util.function.Function-\">collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMap-java.util.function.Function-java.util.function.Function-java.util.function.Supplier>-\">collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMultimap-java.util.function.Function-java.util.function.Function-\">collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMultimap-java.util.function.Function-java.util.function.Function-java.util.function.Supplier>>-\">collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#groupBy-java.util.function.Function-java.util.function.Function-\">groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#groupBy-java.util.function.Function-java.util.function.Function-int-\">groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMap-java.util.function.Function-\">collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectMultimap-java.util.function.Function-\">collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#groupBy-java.util.function.Function-\">groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#groupBy-java.util.function.Function-int-\">groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#error-java.lang.Throwable-boolean-\">error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-java.lang.Iterable>-int-java.util.function.Function-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-java.lang.Iterable>-java.util.function.Function-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#as-java.util.function.Function-P>-\">as</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collect-java.util.stream.Collector-\">collect</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMapIterable-java.util.function.Function>-\">concatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMapIterable-java.util.function.Function>-int-\">concatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnDiscard-java.lang.Class-java.util.function.Consumer-\">doOnDiscard</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMap-java.util.function.Function>-\">flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMap-java.util.function.Function>-java.util.function.Function>-java.util.function.Supplier>-\">flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapIterable-java.util.function.Function>-\">flatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapIterable-java.util.function.Function>-int-\">flatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapSequential-java.util.function.Function>-\">flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapSequential-java.util.function.Function>-int-\">flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapSequential-java.util.function.Function>-int-int-\">flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapSequentialDelayError-java.util.function.Function>-int-int-\">flatMapSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#handle-java.util.function.BiConsumer>-\">handle</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publish-java.util.function.Function-? extends org.reactivestreams.Publisher>-\">publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publish-java.util.function.Function-? extends org.reactivestreams.Publisher>-int-\">publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#using-java.util.concurrent.Callable-java.util.function.Function>-java.util.function.Consumer-\">using</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#using-java.util.concurrent.Callable-java.util.function.Function>-java.util.function.Consumer-boolean-\">using</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#usingWhen-org.reactivestreams.Publisher-java.util.function.Function>-java.util.function.Function>-\">usingWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#usingWhen-org.reactivestreams.Publisher-java.util.function.Function>-java.util.function.Function>-java.util.function.BiFunction>-java.util.function.Function>-\">usingWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#generate-java.util.concurrent.Callable-java.util.function.BiFunction-S>-\">generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#generate-java.util.concurrent.Callable-java.util.function.BiFunction-S>-java.util.function.Consumer-\">generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-java.lang.Iterable>-int-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-java.lang.Iterable>-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-java.util.function.Function-int-org.reactivestreams.Publisher...-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-java.util.function.Function-org.reactivestreams.Publisher...-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.BiFunction-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.Function-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#combineLatest-org.reactivestreams.Publisher-org.reactivestreams.Publisher-java.util.function.BiFunction-\">combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWith-org.reactivestreams.Publisher-int-java.util.function.BiFunction-\">zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWith-org.reactivestreams.Publisher-java.util.function.BiFunction-\">zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWithIterable-java.lang.Iterable-java.util.function.BiFunction-\">zipWithIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWith-org.reactivestreams.Publisher-\">zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWith-org.reactivestreams.Publisher-int-\">zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zipWithIterable-java.lang.Iterable-\">zipWithIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concat-java.lang.Iterable>-\">concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concat-org.reactivestreams.Publisher...-\">concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concat-org.reactivestreams.Publisher>-\">concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concat-org.reactivestreams.Publisher>-int-\">concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatDelayError-org.reactivestreams.Publisher...-\">concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatDelayError-org.reactivestreams.Publisher>-\">concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatDelayError-org.reactivestreams.Publisher>-boolean-int-\">concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatDelayError-org.reactivestreams.Publisher>-int-\">concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#create-java.util.function.Consumer>-\">create</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#create-java.util.function.Consumer>-reactor.core.publisher.FluxSink.OverflowStrategy-\">create</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#defer-java.util.function.Supplier>-\">defer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#deferContextual-java.util.function.Function>-\">deferContextual</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#deferWithContext-java.util.function.Function>-\">deferWithContext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#empty--\">empty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#error-java.lang.Throwable-\">error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#error-java.util.function.Supplier-\">error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#from-org.reactivestreams.Publisher-\">from</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#fromArray-T:A-\">fromArray</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#fromIterable-java.lang.Iterable-\">fromIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#fromStream-java.util.function.Supplier>-\">fromStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#fromStream-java.util.stream.Stream-\">fromStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#generate-java.util.function.Consumer>-\">generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#just-T-\">just</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#just-T...-\">just</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-org.reactivestreams.Publisher>-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-org.reactivestreams.Publisher>-int-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#merge-org.reactivestreams.Publisher>-int-int-\">merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeComparing-int-java.util.Comparator-org.reactivestreams.Publisher...-\">mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeComparing-java.util.Comparator-org.reactivestreams.Publisher...-\">mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeComparingDelayError-int-java.util.Comparator-org.reactivestreams.Publisher...-\">mergeComparingDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeOrdered-int-java.util.Comparator-org.reactivestreams.Publisher...-\">mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeOrdered-java.util.Comparator-org.reactivestreams.Publisher...-\">mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergePriority-int-java.util.Comparator-org.reactivestreams.Publisher...-\">mergePriority</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergePriority-java.util.Comparator-org.reactivestreams.Publisher...-\">mergePriority</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergePriorityDelayError-int-java.util.Comparator-org.reactivestreams.Publisher...-\">mergePriorityDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-org.reactivestreams.Publisher>-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequential-org.reactivestreams.Publisher>-int-int-\">mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeSequentialDelayError-org.reactivestreams.Publisher>-int-int-\">mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#never--\">never</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onAssembly-reactor.core.publisher.ConnectableFlux-\">onAssembly</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onAssembly-reactor.core.publisher.Flux-\">onAssembly</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#push-java.util.function.Consumer>-\">push</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#push-java.util.function.Consumer>-reactor.core.publisher.FluxSink.OverflowStrategy-\">push</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchOnNext-org.reactivestreams.Publisher>-\">switchOnNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchOnNext-org.reactivestreams.Publisher>-int-\">switchOnNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#groupJoin-org.reactivestreams.Publisher-java.util.function.Function>-java.util.function.Function>-java.util.function.BiFunction-? extends R>-\">groupJoin</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#join-org.reactivestreams.Publisher-java.util.function.Function>-java.util.function.Function>-java.util.function.BiFunction-\">join</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher>-java.util.function.Function-\">zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#withLatestFrom-org.reactivestreams.Publisher-java.util.function.BiFunction-\">withLatestFrom</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferWhen-org.reactivestreams.Publisher-java.util.function.Function>-java.util.function.Supplier-\">bufferWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferWhen-org.reactivestreams.Publisher-java.util.function.Function>-\">bufferWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-org.reactivestreams.Publisher-java.util.function.Function>-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-org.reactivestreams.Publisher-java.util.function.Function>-org.reactivestreams.Publisher-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowWhen-org.reactivestreams.Publisher-java.util.function.Function>-\">windowWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delaySubscription-org.reactivestreams.Publisher-\">delaySubscription</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#ofType-java.lang.Class-\">ofType</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sample-org.reactivestreams.Publisher-\">sample</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sampleFirst-java.util.function.Function>-\">sampleFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sampleTimeout-java.util.function.Function>-\">sampleTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sampleTimeout-java.util.function.Function>-int-\">sampleTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-org.reactivestreams.Publisher-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinct-java.util.function.Function-java.util.function.Supplier-\">distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinct-java.util.function.Function-java.util.function.Supplier-java.util.function.BiPredicate-java.util.function.Consumer-\">distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntilChanged--\">bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntilChanged-java.util.function.Function-\">bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntilChanged-java.util.function.Function-java.util.function.BiPredicate-\">bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMap-java.util.function.Function>-\">concatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMap-java.util.function.Function>-int-\">concatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMapDelayError-java.util.function.Function>-\">concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMapDelayError-java.util.function.Function>-boolean-int-\">concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMapDelayError-java.util.function.Function>-int-\">concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinct-java.util.function.Function-\">distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinctUntilChanged-java.util.function.Function-\">distinctUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinctUntilChanged-java.util.function.Function-java.util.function.BiPredicate-\">distinctUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMap-java.util.function.Function>-int-\">flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMap-java.util.function.Function>-int-int-\">flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapDelayError-java.util.function.Function>-int-int-\">flatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#map-java.util.function.Function-\">map</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mapNotNull-java.util.function.Function-\">mapNotNull</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchMap-java.util.function.Function>-\">switchMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchMap-java.util.function.Function>-int-\">switchMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchOnFirst-java.util.function.BiFunction-reactor.core.publisher.Flux-org.reactivestreams.Publisher>-\">switchOnFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchOnFirst-java.util.function.BiFunction-reactor.core.publisher.Flux-org.reactivestreams.Publisher>-boolean-\">switchOnFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#then-reactor.core.publisher.Mono-\">then</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#thenMany-org.reactivestreams.Publisher-\">thenMany</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#transform-java.util.function.Function-? extends org.reactivestreams.Publisher>-\">transform</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#transformDeferred-java.util.function.Function-? extends org.reactivestreams.Publisher>-\">transformDeferred</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#transformDeferredContextual-java.util.function.BiFunction-? super reactor.util.context.ContextView-? extends org.reactivestreams.Publisher>-\">transformDeferredContextual</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntilChanged--\">windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntilChanged-java.util.function.Function-java.util.function.BiPredicate-\">windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntilChanged-java.util.function.Function-\">windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#dematerialize--\">dematerialize</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#all-java.util.function.Predicate-\">all</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#any-java.util.function.Predicate-\">any</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#blockFirst--\">blockFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#blockFirst-java.time.Duration-\">blockFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#blockLast--\">blockLast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#blockLast-java.time.Duration-\">blockLast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer--\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-int-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-int-int-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-java.time.Duration-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-java.time.Duration-java.time.Duration-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-java.time.Duration-java.time.Duration-reactor.core.scheduler.Scheduler-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-java.time.Duration-reactor.core.scheduler.Scheduler-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#buffer-org.reactivestreams.Publisher-\">buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-\">bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-reactor.core.scheduler.Scheduler-\">bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntil-java.util.function.Predicate-\">bufferUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntil-java.util.function.Predicate-boolean-\">bufferUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferWhile-java.util.function.Predicate-\">bufferWhile</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache--\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache-int-\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache-int-java.time.Duration-\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache-int-java.time.Duration-reactor.core.scheduler.Scheduler-\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache-java.time.Duration-\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cache-java.time.Duration-reactor.core.scheduler.Scheduler-\">cache</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#cancelOn-reactor.core.scheduler.Scheduler-\">cancelOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#checkpoint--\">checkpoint</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#checkpoint-java.lang.String-\">checkpoint</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#checkpoint-java.lang.String-boolean-\">checkpoint</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectList--\">collectList</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectSortedList--\">collectSortedList</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#collectSortedList-java.util.Comparator-\">collectSortedList</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatWith-org.reactivestreams.Publisher-\">concatWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatWithValues-T...-\">concatWithValues</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#contextWrite-java.util.function.Function-\">contextWrite</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#contextWrite-reactor.util.context.ContextView-\">contextWrite</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#count--\">count</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#defaultIfEmpty-T-\">defaultIfEmpty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delayElements-java.time.Duration-\">delayElements</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delayElements-java.time.Duration-reactor.core.scheduler.Scheduler-\">delayElements</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delaySequence-java.time.Duration-\">delaySequence</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delaySequence-java.time.Duration-reactor.core.scheduler.Scheduler-\">delaySequence</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delaySubscription-java.time.Duration-\">delaySubscription</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delaySubscription-java.time.Duration-reactor.core.scheduler.Scheduler-\">delaySubscription</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#delayUntil-java.util.function.Function>-\">delayUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinct--\">distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#distinctUntilChanged--\">distinctUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doAfterTerminate-java.lang.Runnable-\">doAfterTerminate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doFinally-java.util.function.Consumer-\">doFinally</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doFirst-java.lang.Runnable-\">doFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnCancel-java.lang.Runnable-\">doOnCancel</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnComplete-java.lang.Runnable-\">doOnComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnEach-java.util.function.Consumer>-\">doOnEach</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnError-java.util.function.Consumer-\">doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnError-java.util.function.Predicate-java.util.function.Consumer-\">doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnNext-java.util.function.Consumer-\">doOnNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnRequest-java.util.function.LongConsumer-\">doOnRequest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnSubscribe-java.util.function.Consumer-\">doOnSubscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnTerminate-java.lang.Runnable-\">doOnTerminate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#elapsed--\">elapsed</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#elapsed-reactor.core.scheduler.Scheduler-\">elapsed</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#elementAt-int-\">elementAt</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#elementAt-int-T-\">elementAt</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expand-java.util.function.Function>-\">expand</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expand-java.util.function.Function>-int-\">expand</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expandDeep-java.util.function.Function>-\">expandDeep</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expandDeep-java.util.function.Function>-int-\">expandDeep</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filter-java.util.function.Predicate-\">filter</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filterWhen-java.util.function.Function>-\">filterWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filterWhen-java.util.function.Function>-int-\">filterWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#getPrefetch--\">getPrefetch</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#hasElement-T-\">hasElement</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#hasElements--\">hasElements</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#hide--\">hide</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#ignoreElements--\">ignoreElements</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#index--\">index</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#interval-java.time.Duration-\">interval</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#interval-java.time.Duration-java.time.Duration-\">interval</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#interval-java.time.Duration-java.time.Duration-reactor.core.scheduler.Scheduler-\">interval</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#interval-java.time.Duration-reactor.core.scheduler.Scheduler-\">interval</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#last--\">last</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#last-T-\">last</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#limitRate-int-\">limitRate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#limitRate-int-int-\">limitRate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#limitRequest-long-\">limitRequest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log--\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log-java.lang.String-\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log-java.lang.String-java.util.logging.Level-boolean-reactor.core.publisher.SignalType...-\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log-java.lang.String-java.util.logging.Level-reactor.core.publisher.SignalType...-\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log-reactor.util.Logger-\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#log-reactor.util.Logger-java.util.logging.Level-boolean-reactor.core.publisher.SignalType...-\">log</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#materialize--\">materialize</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeComparingWith-org.reactivestreams.Publisher-java.util.Comparator-\">mergeComparingWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeOrderedWith-org.reactivestreams.Publisher-java.util.Comparator-\">mergeOrderedWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeWith-org.reactivestreams.Publisher-\">mergeWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#metrics--\">metrics</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#name-java.lang.String-\">name</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#next--\">next</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer--\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-int-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-int-java.util.function.Consumer-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-int-java.util.function.Consumer-reactor.core.publisher.BufferOverflowStrategy-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-int-reactor.core.publisher.BufferOverflowStrategy-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-java.time.Duration-int-java.util.function.Consumer-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-java.time.Duration-int-java.util.function.Consumer-reactor.core.scheduler.Scheduler-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureDrop--\">onBackpressureDrop</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureDrop-java.util.function.Consumer-\">onBackpressureDrop</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureError--\">onBackpressureError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureLatest--\">onBackpressureLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorComplete--\">onErrorComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorComplete-java.lang.Class-\">onErrorComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorComplete-java.util.function.Predicate-\">onErrorComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorContinue-java.util.function.BiConsumer-\">onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorMap-java.util.function.Function-\">onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorMap-java.util.function.Predicate-java.util.function.Function-\">onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorResume-java.util.function.Function>-\">onErrorResume</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorResume-java.util.function.Predicate-java.util.function.Function>-\">onErrorResume</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorReturn-T-\">onErrorReturn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorReturn-java.util.function.Predicate-T-\">onErrorReturn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorStop--\">onErrorStop</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onTerminateDetach--\">onTerminateDetach</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#or-org.reactivestreams.Publisher-\">or</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#parallel--\">parallel</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#parallel-int-\">parallel</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#parallel-int-int-\">parallel</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publish--\">publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publish-int-\">publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishNext--\">publishNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishOn-reactor.core.scheduler.Scheduler-\">publishOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishOn-reactor.core.scheduler.Scheduler-boolean-int-\">publishOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishOn-reactor.core.scheduler.Scheduler-int-\">publishOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#range-int-int-\">range</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#reduce-java.util.function.BiFunction-\">reduce</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#repeat--\">repeat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#repeat-java.util.function.BooleanSupplier-\">repeat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#repeat-long-\">repeat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#repeat-long-java.util.function.BooleanSupplier-\">repeat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#repeatWhen-java.util.function.Function-? extends org.reactivestreams.Publisher>-\">repeatWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay--\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay-int-\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay-int-java.time.Duration-\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay-int-java.time.Duration-reactor.core.scheduler.Scheduler-\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay-java.time.Duration-\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#replay-java.time.Duration-reactor.core.scheduler.Scheduler-\">replay</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#retry--\">retry</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#retry-long-\">retry</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#retryWhen-reactor.util.retry.Retry-\">retryWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sample-java.time.Duration-\">sample</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sampleFirst-java.time.Duration-\">sampleFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#scan-java.util.function.BiFunction-\">scan</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#share--\">share</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#shareNext--\">shareNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#single--\">single</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#single-T-\">single</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#singleOrEmpty--\">singleOrEmpty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skip-java.time.Duration-\">skip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skip-java.time.Duration-reactor.core.scheduler.Scheduler-\">skip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skip-long-\">skip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skipLast-int-\">skipLast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skipUntil-java.util.function.Predicate-\">skipUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skipUntilOther-org.reactivestreams.Publisher-\">skipUntilOther</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#skipWhile-java.util.function.Predicate-\">skipWhile</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sort--\">sort</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#sort-java.util.Comparator-\">sort</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#startWith-T...-\">startWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#startWith-java.lang.Iterable-\">startWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#startWith-org.reactivestreams.Publisher-\">startWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe--\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer-java.util.function.Consumer-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer-java.util.function.Consumer-java.lang.Runnable-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer-java.util.function.Consumer-java.lang.Runnable-java.util.function.Consumer-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer-java.util.function.Consumer-java.lang.Runnable-reactor.util.context.Context-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-org.reactivestreams.Subscriber-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-reactor.core.CoreSubscriber-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribeOn-reactor.core.scheduler.Scheduler-\">subscribeOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribeOn-reactor.core.scheduler.Scheduler-boolean-\">subscribeOn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscriberContext-java.util.function.Function-\">subscriberContext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscriberContext-reactor.util.context.Context-\">subscriberContext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#switchIfEmpty-org.reactivestreams.Publisher-\">switchIfEmpty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#tag-java.lang.String-java.lang.String-\">tag</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#take-java.time.Duration-\">take</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#take-java.time.Duration-reactor.core.scheduler.Scheduler-\">take</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#take-long-\">take</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#take-long-boolean-\">take</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#takeLast-int-\">takeLast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#takeUntil-java.util.function.Predicate-\">takeUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#takeUntilOther-org.reactivestreams.Publisher-\">takeUntilOther</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#takeWhile-java.util.function.Predicate-\">takeWhile</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#then--\">then</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#thenEmpty-org.reactivestreams.Publisher-\">thenEmpty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timed--\">timed</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timed-reactor.core.scheduler.Scheduler-\">timed</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-java.time.Duration-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-java.time.Duration-org.reactivestreams.Publisher-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-java.time.Duration-org.reactivestreams.Publisher-reactor.core.scheduler.Scheduler-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-java.time.Duration-reactor.core.scheduler.Scheduler-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timestamp--\">timestamp</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timestamp-reactor.core.scheduler.Scheduler-\">timestamp</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toIterable--\">toIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toIterable-int-\">toIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toIterable-int-java.util.function.Supplier>-\">toIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toStream--\">toStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toStream-int-\">toStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#toString--\">toString</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-int-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-int-int-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-java.time.Duration-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-java.time.Duration-java.time.Duration-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-java.time.Duration-java.time.Duration-reactor.core.scheduler.Scheduler-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-java.time.Duration-reactor.core.scheduler.Scheduler-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#window-org.reactivestreams.Publisher-\">window</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowTimeout-int-java.time.Duration-\">windowTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowTimeout-int-java.time.Duration-boolean-\">windowTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowTimeout-int-java.time.Duration-reactor.core.scheduler.Scheduler-\">windowTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowTimeout-int-java.time.Duration-reactor.core.scheduler.Scheduler-boolean-\">windowTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntil-java.util.function.Predicate-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntil-java.util.function.Predicate-boolean-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntil-java.util.function.Predicate-boolean-int-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowWhile-java.util.function.Predicate-\">windowWhile</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowWhile-java.util.function.Predicate-int-\">windowWhile</a>"
syntax: "public abstract class **ContinuablePagedFluxCore<C,T,P>**</br> extends <xref href=\"com.azure.core.util.paging.ContinuablePagedFlux?alt=com.azure.core.util.paging.ContinuablePagedFlux&text=ContinuablePagedFlux\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />,<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />,<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;"
constructors:
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.ContinuablePagedFluxCore(java.util.function.Supplier<com.azure.core.util.paging.PageRetriever<C,P>>)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider)"
  name: "ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
  modifiers:
  - "protected"
  parameters:
  - description: "a provider that returns <xref uid=\"com.azure.core.util.paging.PageRetriever\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PageRetriever\"></xref>."
    name: "pageRetrieverProvider"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html\">Supplier</a>&lt;<xref href=\"com.azure.core.util.paging.PageRetriever?alt=com.azure.core.util.paging.PageRetriever&text=PageRetriever\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />,<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;&gt;"
  syntax: "protected ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.ContinuablePagedFluxCore(java.util.function.Supplier<com.azure.core.util.paging.PageRetriever<C,P>>,int)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, int pageSize)"
  name: "ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, int pageSize)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, int pageSize)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
  modifiers:
  - "protected"
  parameters:
  - description: "a provider that returns <xref uid=\"com.azure.core.util.paging.PageRetriever\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PageRetriever\"></xref>."
    name: "pageRetrieverProvider"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html\">Supplier</a>&lt;<xref href=\"com.azure.core.util.paging.PageRetriever?alt=com.azure.core.util.paging.PageRetriever&text=PageRetriever\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />,<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;&gt;"
  - description: "the preferred page size"
    name: "pageSize"
    type: "<xref href=\"int?alt=int&text=int\" data-throw-if-not-resolved=\"False\" />"
  syntax: "protected ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, int pageSize)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.ContinuablePagedFluxCore(java.util.function.Supplier<com.azure.core.util.paging.PageRetriever<C,P>>,java.lang.Integer,java.util.function.Predicate<C>)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, Integer pageSize, Predicate<C> continuationPredicate)"
  name: "ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, Integer pageSize, Predicate<C> continuationPredicate)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, Integer pageSize, Predicate<C> continuationPredicate)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
  modifiers:
  - "protected"
  parameters:
  - description: "A provider that returns <xref uid=\"com.azure.core.util.paging.PageRetriever\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PageRetriever\"></xref>."
    name: "pageRetrieverProvider"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html\">Supplier</a>&lt;<xref href=\"com.azure.core.util.paging.PageRetriever?alt=com.azure.core.util.paging.PageRetriever&text=PageRetriever\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />,<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;&gt;"
  - description: "The preferred page size."
    name: "pageSize"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html\">Integer</a>"
  - description: "A predicate which determines if paging should continue."
    name: "continuationPredicate"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Predicate.html\">Predicate</a>&lt;<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />&gt;"
  syntax: "protected ContinuablePagedFluxCore(Supplier<PageRetriever<C,P>> pageRetrieverProvider, Integer pageSize, Predicate<C> continuationPredicate)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
methods:
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.byPage()"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.byPage()"
  name: "byPage()"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.byPage()"
  summary: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> starting at the first page."
  overridden: "com.azure.core.util.paging.ContinuablePagedFlux.byPage()"
  syntax: "public Flux<P> byPage()"
  desc: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> starting at the first page."
  returns:
    type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html\">Flux</a>&lt;<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(C)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.byPage(C continuationToken)"
  name: "byPage(C continuationToken)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.byPage(C continuationToken)"
  summary: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> beginning at the page identified by the given continuation token."
  overridden: "com.azure.core.util.paging.ContinuablePagedFlux.byPage(C)"
  parameters:
  - name: "continuationToken"
    type: "<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />"
  syntax: "public Flux<P> byPage(C continuationToken)"
  desc: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> beginning at the page identified by the given continuation token."
  returns:
    type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html\">Flux</a>&lt;<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(C,int)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.byPage(C continuationToken, int preferredPageSize)"
  name: "byPage(C continuationToken, int preferredPageSize)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.byPage(C continuationToken, int preferredPageSize)"
  summary: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> beginning at the page identified by the given continuation token requesting each page to contain the number of elements equal to the preferred page size."
  overridden: "com.azure.core.util.paging.ContinuablePagedFlux.byPage(C,int)"
  parameters:
  - name: "continuationToken"
    type: "<xref href=\"C?alt=C&text=C\" data-throw-if-not-resolved=\"False\" />"
  - name: "preferredPageSize"
    type: "<xref href=\"int?alt=int&text=int\" data-throw-if-not-resolved=\"False\" />"
  syntax: "public Flux<P> byPage(C continuationToken, int preferredPageSize)"
  desc: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> beginning at the page identified by the given continuation token requesting each page to contain the number of elements equal to the preferred page size.\n\nThe service may or may not honor the preferred page size therefore the client *MUST* be prepared to handle pages with different page sizes."
  returns:
    type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html\">Flux</a>&lt;<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(int)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.byPage(int preferredPageSize)"
  name: "byPage(int preferredPageSize)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.byPage(int preferredPageSize)"
  summary: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> starting at the first page requesting each page to contain a number of elements equal to the preferred page size."
  overridden: "com.azure.core.util.paging.ContinuablePagedFlux.byPage(int)"
  parameters:
  - name: "preferredPageSize"
    type: "<xref href=\"int?alt=int&text=int\" data-throw-if-not-resolved=\"False\" />"
  syntax: "public Flux<P> byPage(int preferredPageSize)"
  desc: "Gets a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> starting at the first page requesting each page to contain a number of elements equal to the preferred page size.\n\nThe service may or may not honor the preferred page size therefore the client *MUST* be prepared to handle pages with different page sizes."
  returns:
    type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html\">Flux</a>&lt;<xref href=\"P?alt=P&text=P\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.getPageSize()"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.getPageSize()"
  name: "getPageSize()"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.getPageSize()"
  summary: "Get the page size configured this <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
  syntax: "public Integer getPageSize()"
  desc: "Get the page size configured this <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>."
  returns:
    description: "the page size configured, <code>null</code> if unspecified."
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html\">Integer</a>"
- uid: "com.azure.core.util.paging.ContinuablePagedFluxCore.subscribe(reactor.core.CoreSubscriber<? super T>)"
  fullName: "com.azure.core.util.paging.ContinuablePagedFluxCore<C,T,P>.subscribe(CoreSubscriber<? super T> coreSubscriber)"
  name: "subscribe(CoreSubscriber<? super T> coreSubscriber)"
  nameWithType: "ContinuablePagedFluxCore<C,T,P>.subscribe(CoreSubscriber<? super T> coreSubscriber)"
  summary: "Subscribe to consume all items of type `T` in the sequence respectively."
  overridden: "reactor.core.publisher.Flux.subscribe(reactor.core.CoreSubscriber<? super T>)"
  parameters:
  - description: "The subscriber for this <xref uid=\"com.azure.core.util.paging.ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFluxCore\"></xref>"
    name: "coreSubscriber"
    type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/CoreSubscriber.html\">CoreSubscriber</a>&lt;<xref href=\"? super T?alt=? super T&text=? super T\" data-throw-if-not-resolved=\"False\" />&gt;"
  syntax: "public void subscribe(CoreSubscriber<? super T> coreSubscriber)"
  desc: "Subscribe to consume all items of type `T` in the sequence respectively. This is recommended for most common scenarios. This will seamlessly fetch next page when required and provide with a <xref uid=\"reactor.core.publisher.Flux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Flux\"></xref> of items."
type: "class"
typeParameters:
- description: "the type of the continuation token"
  name: "C"
- description: "The type of elements in a <xref uid=\"ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref>"
  name: "T"
- description: "The <xref uid=\"ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> holding items of type <code>T</code>."
  name: "P"
desc: "The default implementation of <xref uid=\"com.azure.core.util.paging.ContinuablePagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePagedFlux\"></xref>.\n\nThis type is a Flux that provides the ability to operate on pages of type <xref uid=\"com.azure.core.util.paging.ContinuablePage\" data-throw-if-not-resolved=\"false\" data-raw-source=\"ContinuablePage\"></xref> and individual items in such pages. This type supports user-provided continuation tokens, allowing for restarting from a previously-retrieved continuation token.\n\nThe type is backed by the Page Retriever provider provided in it's constructor. The provider is expected to return <xref uid=\"com.azure.core.util.paging.PageRetriever\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PageRetriever\"></xref> when called. The provider is invoked for each Subscription to this Flux. Given provider is called per Subscription, the provider implementation can create one or more objects to store any state and Page Retriever can capture and use those objects. This indirectly associate the state objects to the Subscription. The Page Retriever can get called multiple times in serial fashion, each time after the completion of the Flux returned by the previous invocation. The final completion signal will be send to the Subscriber when the last Page emitted by the Flux returned by the Page Retriever has `null` continuation token.\n\n**Extending PagedFluxCore for Custom Continuation Token support**\n\n```java\nclass ContinuationState<C> {\n     private C lastContinuationToken;\n     private boolean isDone;\n\n     ContinuationState(C token) {\n         this.lastContinuationToken = token;\n     }\n\n     void setLastContinuationToken(C token) {\n         this.isDone = token == null;\n         this.lastContinuationToken = token;\n     }\n\n     C getLastContinuationToken() {\n         return this.lastContinuationToken;\n     }\n\n     boolean isDone() {\n         return this.isDone;\n     }\n }\n\n class FileContinuationToken {\n     private final int nextLinkId;\n\n     FileContinuationToken(int nextLinkId) {\n         this.nextLinkId = nextLinkId;\n     }\n\n     public int getNextLinkId() {\n         return nextLinkId;\n     }\n }\n\n class File {\n     private final String guid;\n\n     File(String guid) {\n         this.guid = guid;\n     }\n\n     public String getGuid() {\n         return guid;\n     }\n }\n\n class FilePage implements ContinuablePage<FileContinuationToken, File> {\n     private final IterableStream<File> elements;\n     private final FileContinuationToken fileContinuationToken;\n\n     FilePage(List<File> elements, FileContinuationToken fileContinuationToken) {\n         this.elements = IterableStream.of(elements);\n         this.fileContinuationToken = fileContinuationToken;\n     }\n\n     @Override\n     public IterableStream<File> getElements() {\n         return elements;\n     }\n\n     @Override\n     public FileContinuationToken getContinuationToken() {\n         return fileContinuationToken;\n     }\n }\n\n class FileShareServiceClient {\n     Flux<FilePage> getFilePages(FileContinuationToken token) {\n         List<File> files = Collections.singletonList(new File(UUID.randomUUID().toString()));\n         if (token.getNextLinkId() < 10) {\n             return Flux.just(new FilePage(files, null));\n         } else {\n             return Flux.just(new FilePage(files,\n                 new FileContinuationToken((int) Math.floor(Math.random() * 20))));\n         }\n     }\n }\n\n FileShareServiceClient client = new FileShareServiceClient();\n\n Supplier<PageRetriever<FileContinuationToken, FilePage>> pageRetrieverProvider = () ->\n     (continuationToken, pageSize) -> client.getFilePages(continuationToken);\n\n class FilePagedFlux extends ContinuablePagedFluxCore<FileContinuationToken, File, FilePage> {\n     FilePagedFlux(Supplier<PageRetriever<FileContinuationToken, FilePage>>\n         pageRetrieverProvider) {\n         super(pageRetrieverProvider);\n     }\n }\n\n FilePagedFlux filePagedFlux = new FilePagedFlux(pageRetrieverProvider);\n```"
metadata: {}
package: "com.azure.core.util.paging"
artifact: com.azure:azure-core:1.52.0