com.azure.core.http.rest.PagedFlux.yml

### YamlMime:JavaType
uid: "com.azure.core.http.rest.PagedFlux"
fullName: "com.azure.core.http.rest.PagedFlux<T>"
name: "PagedFlux<T>"
nameWithType: "PagedFlux<T>"
summary: "Paged<wbr>Flux is a Flux that provides the ability to operate on paginated REST responses of type <xref uid=\"com.azure.core.http.rest.PagedResponse\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedResponse\"></xref> and individual items in such pages."
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\" />"
- "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore?displayProperty=fullName\" data-throw-if-not-resolved=\"False\" />"
- "<xref href=\"com.azure.core.http.rest.PagedFluxBase?displayProperty=fullName\" data-throw-if-not-resolved=\"False\" />"
inheritedClassMethods:
- classRef: "<xref href=\"com.azure.core.http.rest.PagedFluxBase?alt=com.azure.core.http.rest.PagedFluxBase&text=PagedFluxBase\" data-throw-if-not-resolved=\"False\" />"
  methodsRef:
  - "<xref href=\"com.azure.core.http.rest.PagedFluxBase.byPage()?alt=com.azure.core.http.rest.PagedFluxBase.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.http.rest.PagedFluxBase.byPage(java.lang.String)?alt=com.azure.core.http.rest.PagedFluxBase.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.http.rest.PagedFluxBase.subscribe(reactor.core.CoreSubscriber<? super T>)?alt=com.azure.core.http.rest.PagedFluxBase.subscribe&text=subscribe\" data-throw-if-not-resolved=\"False\" />"
- 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.getContinuationPredicate()?alt=com.azure.core.util.paging.ContinuablePagedFlux.getContinuationPredicate&text=getContinuationPredicate\" data-throw-if-not-resolved=\"False\" />"
- classRef: "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore?alt=com.azure.core.util.paging.ContinuablePagedFluxCore&text=ContinuablePagedFluxCore\" data-throw-if-not-resolved=\"False\" />"
  methodsRef:
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(C)?alt=com.azure.core.util.paging.ContinuablePagedFluxCore.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(C,int)?alt=com.azure.core.util.paging.ContinuablePagedFluxCore.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore.byPage(int)?alt=com.azure.core.util.paging.ContinuablePagedFluxCore.byPage&text=byPage\" data-throw-if-not-resolved=\"False\" />"
  - "<xref href=\"com.azure.core.util.paging.ContinuablePagedFluxCore.getPageSize()?alt=com.azure.core.util.paging.ContinuablePagedFluxCore.getPageSize&text=getPageSize\" 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#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 class **PagedFlux<T>**</br> extends <xref href=\"com.azure.core.http.rest.PagedFluxBase?alt=com.azure.core.http.rest.PagedFluxBase&text=PagedFluxBase\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />,<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;"
constructors:
- uid: "com.azure.core.http.rest.PagedFlux.PagedFlux(java.util.function.Function<java.lang.Integer,reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever)"
  name: "PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever)"
  nameWithType: "PagedFlux<T>.PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that consists of only a single page with a given element count."
  parameters:
  - description: "Function that retrieves the first page."
    name: "firstPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html\">Function</a>&lt;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html\">Integer</a>,<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  syntax: "public PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that consists of only a single page with a given element count.\n\n**Code sample**\n\n```java\n// A function that fetches the single page of data from a source/service.\n Function<Integer, Mono<PagedResponse<Integer>>> singlePageRetriever = pageSize ->\n     getFirstPageWithSize(pageSize);\n\n PagedFlux<Integer> singlePageFluxWithPageSize = new PagedFlux<Integer>(singlePageRetriever);\n```"
- uid: "com.azure.core.http.rest.PagedFlux.PagedFlux(java.util.function.Function<java.lang.Integer,reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>,java.util.function.BiFunction<java.lang.String,java.lang.Integer,reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever, BiFunction<String,Integer,Mono<PagedResponse<T>>> nextPageRetriever)"
  name: "PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever, BiFunction<String,Integer,Mono<PagedResponse<T>>> nextPageRetriever)"
  nameWithType: "PagedFlux<T>.PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever, BiFunction<String,Integer,Mono<PagedResponse<T>>> nextPageRetriever)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that is capable of retrieving multiple pages with of a given page size."
  parameters:
  - description: "Function that retrieves the first page."
    name: "firstPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html\">Function</a>&lt;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html\">Integer</a>,<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  - description: "BiFunction that retrieves the next page given a continuation token and page size."
    name: "nextPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/BiFunction.html\">BiFunction</a>&lt;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/String.html\">String</a>,<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html\">Integer</a>,<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  syntax: "public PagedFlux(Function<Integer,Mono<PagedResponse<T>>> firstPageRetriever, BiFunction<String,Integer,Mono<PagedResponse<T>>> nextPageRetriever)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that is capable of retrieving multiple pages with of a given page size.\n\n**Code sample**\n\n```java\n// A function that fetches the first page of data from a source/service.\n Function<Integer, Mono<PagedResponse<Integer>>> firstPageRetriever = pageSize -> getFirstPageWithSize(pageSize);\n\n // A function that fetches subsequent pages of data from a source/service given a continuation token.\n BiFunction<String, Integer, Mono<PagedResponse<Integer>>> nextPageRetriever = (continuationToken, pageSize) ->\n     getNextPageWithSize(continuationToken, pageSize);\n\n PagedFlux<Integer> pagedFluxWithPageSize = new PagedFlux<>(firstPageRetriever, nextPageRetriever);\n```"
- uid: "com.azure.core.http.rest.PagedFlux.PagedFlux(java.util.function.Supplier<reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever)"
  name: "PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever)"
  nameWithType: "PagedFlux<T>.PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that consists of only a single page."
  parameters:
  - description: "Supplier that retrieves the first page."
    name: "firstPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html\">Supplier</a>&lt;<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  syntax: "public PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> that consists of only a single page. This constructor takes a `Supplier` that return the single page of `T`.\n\n**Code sample**\n\n```java\n// A supplier that fetches the first page of data from source/service\n Supplier<Mono<PagedResponse<Integer>>> firstPageRetrieverFunction = () -> getFirstPage();\n\n PagedFlux<Integer> pagedFluxInstance = new PagedFlux<>(firstPageRetrieverFunction,\n     nextPageRetriever);\n```"
- uid: "com.azure.core.http.rest.PagedFlux.PagedFlux(java.util.function.Supplier<reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>,java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<com.azure.core.http.rest.PagedResponse<T>>>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever, Function<String,Mono<PagedResponse<T>>> nextPageRetriever)"
  name: "PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever, Function<String,Mono<PagedResponse<T>>> nextPageRetriever)"
  nameWithType: "PagedFlux<T>.PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever, Function<String,Mono<PagedResponse<T>>> nextPageRetriever)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref>."
  parameters:
  - description: "Supplier that retrieves the first page"
    name: "firstPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html\">Supplier</a>&lt;<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  - description: "Function that retrieves the next page given a continuation token"
    name: "nextPageRetriever"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html\">Function</a>&lt;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/String.html\">String</a>,<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  syntax: "public PagedFlux(Supplier<Mono<PagedResponse<T>>> firstPageRetriever, Function<String,Mono<PagedResponse<T>>> nextPageRetriever)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref>. The constructor takes a `Supplier` and `Function`. The `Supplier` returns the first page of `T`, the `Function` retrieves subsequent pages of `T`.\n\n**Code sample**\n\n```java\n// A supplier that fetches the first page of data from source/service\n Supplier<Mono<PagedResponse<Integer>>> firstPageRetriever = () -> getFirstPage();\n\n // A function that fetches subsequent pages of data from source/service given a continuation token\n Function<String, Mono<PagedResponse<Integer>>> nextPageRetriever =\n     continuationToken -> getNextPage(continuationToken);\n\n PagedFlux<Integer> pagedFlux = new PagedFlux<>(firstPageRetriever,\n     nextPageRetriever);\n```"
methods:
- uid: "com.azure.core.http.rest.PagedFlux.<S>mapPage(java.util.function.Function<T,S>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.mapPage(Function<T,S> mapper)"
  name: "mapPage(Function<T,S> mapper)"
  nameWithType: "PagedFlux<T>.mapPage(Function<T,S> mapper)"
  summary: "Maps this Paged<wbr>Flux instance of T to a Paged<wbr>Flux instance of type S as per the provided mapper function."
  deprecatedTag: "refer the decoration samples for <xref uid=\"com.azure.core.http.rest.PagedFlux.create*\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux#create(Supplier)\"></xref>."
  parameters:
  - description: "The mapper function to convert from type T to type S."
    name: "mapper"
    type: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html\">Function</a>&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />,<xref href=\"S?alt=S&text=S\" data-throw-if-not-resolved=\"False\" />&gt;"
  syntax: "<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html\">@Deprecated</a></br>public PagedFlux<S> <S>mapPage(Function<T,S> mapper)"
  desc: "Maps this PagedFlux instance of T to a PagedFlux instance of type S as per the provided mapper function."
  hasDeprecatedTag: true
  returns:
    description: "A PagedFlux of type S."
    type: "<xref href=\"com.azure.core.http.rest.PagedFlux?alt=com.azure.core.http.rest.PagedFlux&text=PagedFlux\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"S?alt=S&text=S\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.http.rest.PagedFlux.<T>create(java.util.function.Supplier<com.azure.core.util.paging.PageRetriever<java.lang.String,com.azure.core.http.rest.PagedResponse<T>>>)"
  fullName: "com.azure.core.http.rest.PagedFlux<T>.create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  name: "create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  nameWithType: "PagedFlux<T>.create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  summary: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> backed by a Page Retriever Supplier (provider)."
  modifiers:
  - "static"
  parameters:
  - description: "the Page Retrieval Provider"
    name: "provider"
    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;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/String.html\">String</a>,<xref href=\"com.azure.core.http.rest.PagedResponse?alt=com.azure.core.http.rest.PagedResponse&text=PagedResponse\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;&gt;&gt;"
  syntax: "public static PagedFlux<T> <T>create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  desc: "Creates an instance of <xref uid=\"com.azure.core.http.rest.PagedFlux\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedFlux\"></xref> backed by a Page Retriever Supplier (provider). When invoked provider should return <xref uid=\"com.azure.core.util.paging.PageRetriever\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PageRetriever\"></xref>. The provider will be called for each Subscription to the PagedFlux instance. The Page Retriever can get called multiple times in serial fashion, each time after the completion of the Flux returned from the previous invocation. The final completion signal will be send to the Subscriber when the last Page emitted by the Flux returned by Page Retriever has `null` continuation token. The provider is useful mainly in two scenarios:\n\n *  To manage state across multiple call to Page Retrieval within the same Subscription.\n *  To decorate a PagedFlux to produce new PagedFlux.\n\n**Decoration sample**\n\n```java\n// Transform a PagedFlux with Integer items to PagedFlux of String items.\n final PagedFlux<Integer> intPagedFlux = createAnInstance();\n\n // PagedResponse<Integer> to PagedResponse<String> mapper\n final Function<PagedResponse<Integer>, PagedResponse<String>> responseMapper\n     = intResponse -> new PagedResponseBase<Void, String>(intResponse.getRequest(),\n     intResponse.getStatusCode(),\n     intResponse.getHeaders(),\n     intResponse.getValue()\n         .stream()\n         .map(intValue -> Integer.toString(intValue)).collect(Collectors.toList()),\n     intResponse.getContinuationToken(),\n     null);\n\n final Supplier<PageRetriever<String, PagedResponse<String>>> provider = () ->\n     (continuationToken, pageSize) -> {\n         Flux<PagedResponse<Integer>> flux = (continuationToken == null)\n             ? intPagedFlux.byPage()\n             : intPagedFlux.byPage(continuationToken);\n         return flux.map(responseMapper);\n     };\n PagedFlux<String> strPagedFlux = PagedFlux.create(provider);\n\n // Create a PagedFlux from a PagedFlux with all exceptions mapped to a specific exception.\n final PagedFlux<Integer> pagedFlux = createAnInstance();\n final Supplier<PageRetriever<String, PagedResponse<Integer>>> eprovider = () ->\n     (continuationToken, pageSize) -> {\n         Flux<PagedResponse<Integer>> flux = (continuationToken == null)\n             ? pagedFlux.byPage()\n             : pagedFlux.byPage(continuationToken);\n         return flux.onErrorMap(Exception.class, PaginationException::new);\n     };\n final PagedFlux<Integer> exceptionMappedPagedFlux = PagedFlux.create(eprovider);\n```"
  returns:
    description: "PagedFlux backed by the Page Retriever Function Supplier"
    type: "<xref href=\"com.azure.core.http.rest.PagedFlux?alt=com.azure.core.http.rest.PagedFlux&text=PagedFlux\" data-throw-if-not-resolved=\"False\" />&lt;<xref href=\"T?alt=T&text=T\" data-throw-if-not-resolved=\"False\" />&gt;"
type: "class"
typeParameters:
- description: "The type of items in a <xref uid=\"PagedResponse\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedResponse\"></xref>"
  name: "T"
desc: "PagedFlux is a Flux that provides the ability to operate on paginated REST responses of type <xref uid=\"com.azure.core.http.rest.PagedResponse\" data-throw-if-not-resolved=\"false\" data-raw-source=\"PagedResponse\"></xref> and individual items in such pages. When processing the response by page each response will contain the items in the page as well as the REST response details such as status code and headers.\n\nTo process one item at a time, simply subscribe to this flux as shown below\n\n**Code sample**\n\n```java\n// Subscribe to process one item at a time\n pagedFlux\n     .log()\n     .subscribe(item -> System.out.println(\"Processing item with value: \" + item),\n         error -> System.err.println(\"An error occurred: \" + error),\n         () -> System.out.println(\"Processing complete.\"));\n```\n\nTo process one page at a time, use <xref uid=\"com.azure.core.http.rest.PagedFlux.byPage*\" data-throw-if-not-resolved=\"false\" data-raw-source=\"#byPage()\"></xref> method as shown below\n\n**Code sample**\n\n```java\n// Subscribe to process one page at a time from the beginning\n pagedFlux\n     .byPage()\n     .log()\n     .subscribe(page -> System.out.printf(\"Processing page containing item values: %s%n\",\n         page.getElements().stream().map(String::valueOf).collect(Collectors.joining(\", \"))),\n         error -> System.err.println(\"An error occurred: \" + error),\n         () -> System.out.println(\"Processing complete.\"));\n```\n\nTo process items one page at a time starting from any page associated with a continuation token, use <xref uid=\"com.azure.core.http.rest.PagedFlux.byPage*\" data-throw-if-not-resolved=\"false\" data-raw-source=\"#byPage(String)\"></xref> as shown below\n\n**Code sample**\n\n```java\n// Subscribe to process one page at a time starting from a page associated with\n // a continuation token\n String continuationToken = getContinuationToken();\n pagedFlux\n     .byPage(continuationToken)\n     .log()\n     .doOnSubscribe(ignored -> System.out.println(\n         \"Subscribed to paged flux processing pages starting from: \" + continuationToken))\n     .subscribe(page -> System.out.printf(\"Processing page containing item values: %s%n\",\n         page.getElements().stream().map(String::valueOf).collect(Collectors.joining(\", \"))),\n         error -> System.err.println(\"An error occurred: \" + error),\n         () -> System.out.println(\"Processing complete.\"));\n```"
metadata: {}
package: "com.azure.core.http.rest"
artifact: com.azure:azure-core:1.51.0