azure-docs-sdk-java/docs-ref-autogen/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#<A>reduce-A-java.util.function.BiFunction<A-? super T-A>-\"><A>reduce</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<A>reduceWith-java.util.function.Supplier<A>-java.util.function.BiFunction<A-? super T-A>-\"><A>reduceWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<A>scan-A-java.util.function.BiFunction<A-? super T-A>-\"><A>scan</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<A>scanWith-java.util.function.Supplier<A>-java.util.function.BiFunction<A-? super T-A>-\"><A>scanWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<C>buffer-int-int-java.util.function.Supplier<C>-\"><C>buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<C>buffer-int-java.util.function.Supplier<C>-\"><C>buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<C>buffer-org.reactivestreams.Publisher<?>-java.util.function.Supplier<C>-\"><C>buffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<C>bufferTimeout-int-java.time.Duration-java.util.function.Supplier<C>-\"><C>bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<C>bufferTimeout-int-java.time.Duration-reactor.core.scheduler.Scheduler-java.util.function.Supplier<C>-\"><C>bufferTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>cast-java.lang.Class<E>-\"><E>cast</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>collect-java.util.function.Supplier<E>-java.util.function.BiConsumer<E-? super T>-\"><E>collect</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>doOnError-java.lang.Class<E>-java.util.function.Consumer<? super E>-\"><E>doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>onErrorContinue-java.lang.Class<E>-java.util.function.BiConsumer<java.lang.Throwable-java.lang.Object>-\"><E>onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>onErrorContinue-java.util.function.Predicate<E>-java.util.function.BiConsumer<java.lang.Throwable-java.lang.Object>-\"><E>onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>onErrorMap-java.lang.Class<E>-java.util.function.Function<? super E-? extends java.lang.Throwable>-\"><E>onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>onErrorResume-java.lang.Class<E>-java.util.function.Function<? super E-? extends org.reactivestreams.Publisher<? extends T>>-\"><E>onErrorResume</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>onErrorReturn-java.lang.Class<E>-T-\"><E>onErrorReturn</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<E>subscribeWith-E-\"><E>subscribeWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I-O>zip-java.util.function.Function<? super java.lang.Object[]-? extends O>-int-org.reactivestreams.Publisher<? extends I>...-\"><I,O>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I-O>zip-java.util.function.Function<? super java.lang.Object[]-? extends O>-org.reactivestreams.Publisher<? extends I>...-\"><I,O>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>first-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-\"><I>first</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>first-org.reactivestreams.Publisher<? extends I>...-\"><I>first</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>firstWithSignal-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-\"><I>firstWithSignal</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>firstWithSignal-org.reactivestreams.Publisher<? extends I>...-\"><I>firstWithSignal</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>firstWithValue-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-\"><I>firstWithValue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>firstWithValue-org.reactivestreams.Publisher<? extends I>-org.reactivestreams.Publisher<? extends I>...-\"><I>firstWithValue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>index-java.util.function.BiFunction<? super java.lang.Long-? super T-? extends I>-\"><I>index</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>merge-int-org.reactivestreams.Publisher<? extends I>...-\"><I>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>merge-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-\"><I>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>merge-org.reactivestreams.Publisher<? extends I>...-\"><I>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeComparing-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeDelayError-int-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeOrdered-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequential-int-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequential-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-\"><I>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequential-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-int-int-\"><I>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequential-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequentialDelayError-int-org.reactivestreams.Publisher<? extends I>...-\"><I>mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<I>mergeSequentialDelayError-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends I>>-int-int-\"><I>mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>collectMap-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-\"><K,V>collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>collectMap-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-java.util.function.Supplier<java.util.Map<K-V>>-\"><K,V>collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>collectMultimap-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-\"><K,V>collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>collectMultimap-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-java.util.function.Supplier<java.util.Map<K-java.util.Collection<V>>>-\"><K,V>collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>groupBy-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-\"><K,V>groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K-V>groupBy-java.util.function.Function<? super T-? extends K>-java.util.function.Function<? super T-? extends V>-int-\"><K,V>groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K>collectMap-java.util.function.Function<? super T-? extends K>-\"><K>collectMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K>collectMultimap-java.util.function.Function<? super T-? extends K>-\"><K>collectMultimap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K>groupBy-java.util.function.Function<? super T-? extends K>-\"><K>groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<K>groupBy-java.util.function.Function<? super T-? extends K>-int-\"><K>groupBy</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<O>error-java.lang.Throwable-boolean-\"><O>error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<O>zip-java.lang.Iterable<? extends org.reactivestreams.Publisher<?>>-int-java.util.function.Function<? super java.lang.Object[]-? extends O>-\"><O>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<O>zip-java.lang.Iterable<? extends org.reactivestreams.Publisher<?>>-java.util.function.Function<? super java.lang.Object[]-? extends O>-\"><O>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<P>as-java.util.function.Function<? super reactor.core.publisher.Flux<T>-P>-\"><P>as</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R-A>collect-java.util.stream.Collector<? super T-A-? extends R>-\"><R,A>collect</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>concatMapIterable-java.util.function.Function<? super T-? extends java.lang.Iterable<? extends R>>-\"><R>concatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>concatMapIterable-java.util.function.Function<? super T-? extends java.lang.Iterable<? extends R>>-int-\"><R>concatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>doOnDiscard-java.lang.Class<R>-java.util.function.Consumer<? super R>-\"><R>doOnDiscard</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-\"><R>flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-java.util.function.Function<? super java.lang.Throwable-? extends org.reactivestreams.Publisher<? extends R>>-java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends R>>-\"><R>flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapIterable-java.util.function.Function<? super T-? extends java.lang.Iterable<? extends R>>-\"><R>flatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapIterable-java.util.function.Function<? super T-? extends java.lang.Iterable<? extends R>>-int-\"><R>flatMapIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapSequential-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-\"><R>flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapSequential-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-int-\"><R>flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapSequential-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-int-int-\"><R>flatMapSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>flatMapSequentialDelayError-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends R>>-int-int-\"><R>flatMapSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>handle-java.util.function.BiConsumer<? super T-reactor.core.publisher.SynchronousSink<R>>-\"><R>handle</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>publish-java.util.function.Function<? super reactor.core.publisher.Flux<T>-? extends org.reactivestreams.Publisher<? extends R>>-\"><R>publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<R>publish-java.util.function.Function<? super reactor.core.publisher.Flux<T>-? extends org.reactivestreams.Publisher<? extends R>>-int-\"><R>publish</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-D>using-java.util.concurrent.Callable<? extends D>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<? extends T>>-java.util.function.Consumer<? super D>-\"><T,D>using</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-D>using-java.util.concurrent.Callable<? extends D>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<? extends T>>-java.util.function.Consumer<? super D>-boolean-\"><T,D>using</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-D>usingWhen-org.reactivestreams.Publisher<D>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<? extends T>>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<?>>-\"><T,D>usingWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-D>usingWhen-org.reactivestreams.Publisher<D>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<? extends T>>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<?>>-java.util.function.BiFunction<? super D-? super java.lang.Throwable-? extends org.reactivestreams.Publisher<?>>-java.util.function.Function<? super D-? extends org.reactivestreams.Publisher<?>>-\"><T,D>usingWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-S>generate-java.util.concurrent.Callable<S>-java.util.function.BiFunction<S-reactor.core.publisher.SynchronousSink<T>-S>-\"><T,S>generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-S>generate-java.util.concurrent.Callable<S>-java.util.function.BiFunction<S-reactor.core.publisher.SynchronousSink<T>-S>-java.util.function.Consumer<? super S>-\"><T,S>generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-V>combineLatest-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>-int-java.util.function.Function<java.lang.Object[]-V>-\"><T,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-V>combineLatest-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>-java.util.function.Function<java.lang.Object[]-V>-\"><T,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-V>combineLatest-java.util.function.Function<java.lang.Object[]-V>-int-org.reactivestreams.Publisher<? extends T>...-\"><T,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T-V>combineLatest-java.util.function.Function<java.lang.Object[]-V>-org.reactivestreams.Publisher<? extends T>...-\"><T,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-O>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-java.util.function.BiFunction<? super T1-? super T2-? extends O>-\"><T1,T2,O>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5-T6-T7-T8>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-org.reactivestreams.Publisher<? extends T6>-org.reactivestreams.Publisher<? extends T7>-org.reactivestreams.Publisher<? extends T8>-\"><T1,T2,T3,T4,T5,T6,T7,T8>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5-T6-T7>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-org.reactivestreams.Publisher<? extends T6>-org.reactivestreams.Publisher<? extends T7>-\"><T1,T2,T3,T4,T5,T6,T7>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5-T6-V>combineLatest-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-org.reactivestreams.Publisher<? extends T6>-java.util.function.Function<java.lang.Object[]-V>-\"><T1,T2,T3,T4,T5,T6,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5-T6>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-org.reactivestreams.Publisher<? extends T6>-\"><T1,T2,T3,T4,T5,T6>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5-V>combineLatest-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-java.util.function.Function<java.lang.Object[]-V>-\"><T1,T2,T3,T4,T5,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-T5>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-org.reactivestreams.Publisher<? extends T5>-\"><T1,T2,T3,T4,T5>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4-V>combineLatest-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-java.util.function.Function<java.lang.Object[]-V>-\"><T1,T2,T3,T4,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-T4>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-org.reactivestreams.Publisher<? extends T4>-\"><T1,T2,T3,T4>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3-V>combineLatest-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-java.util.function.Function<java.lang.Object[]-V>-\"><T1,T2,T3,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-T3>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-org.reactivestreams.Publisher<? extends T3>-\"><T1,T2,T3>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2-V>combineLatest-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-java.util.function.BiFunction<? super T1-? super T2-? extends V>-\"><T1,T2,V>combineLatest</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T1-T2>zip-org.reactivestreams.Publisher<? extends T1>-org.reactivestreams.Publisher<? extends T2>-\"><T1,T2>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2-V>zipWith-org.reactivestreams.Publisher<? extends T2>-int-java.util.function.BiFunction<? super T-? super T2-? extends V>-\"><T2,V>zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2-V>zipWith-org.reactivestreams.Publisher<? extends T2>-java.util.function.BiFunction<? super T-? super T2-? extends V>-\"><T2,V>zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2-V>zipWithIterable-java.lang.Iterable<? extends T2>-java.util.function.BiFunction<? super T-? super T2-? extends V>-\"><T2,V>zipWithIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2>zipWith-org.reactivestreams.Publisher<? extends T2>-\"><T2>zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2>zipWith-org.reactivestreams.Publisher<? extends T2>-int-\"><T2>zipWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T2>zipWithIterable-java.lang.Iterable<? extends T2>-\"><T2>zipWithIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concat-java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concat-org.reactivestreams.Publisher<? extends T>...-\"><T>concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concat-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concat-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-\"><T>concat</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concatDelayError-org.reactivestreams.Publisher<? extends T>...-\"><T>concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concatDelayError-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concatDelayError-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-boolean-int-\"><T>concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>concatDelayError-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-\"><T>concatDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>create-java.util.function.Consumer<? super reactor.core.publisher.FluxSink<T>>-\"><T>create</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>create-java.util.function.Consumer<? super reactor.core.publisher.FluxSink<T>>-reactor.core.publisher.FluxSink.OverflowStrategy-\"><T>create</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>defer-java.util.function.Supplier<? extends org.reactivestreams.Publisher<T>>-\"><T>defer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>deferContextual-java.util.function.Function<reactor.util.context.ContextView-? extends org.reactivestreams.Publisher<T>>-\"><T>deferContextual</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>deferWithContext-java.util.function.Function<reactor.util.context.Context-? extends org.reactivestreams.Publisher<T>>-\"><T>deferWithContext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>empty--\"><T>empty</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>error-java.lang.Throwable-\"><T>error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>error-java.util.function.Supplier<? extends java.lang.Throwable>-\"><T>error</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>from-org.reactivestreams.Publisher<? extends T>-\"><T>from</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>fromArray-T[]-\"><T>fromArray</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>fromIterable-java.lang.Iterable<? extends T>-\"><T>fromIterable</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>fromStream-java.util.function.Supplier<java.util.stream.Stream<? extends T>>-\"><T>fromStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>fromStream-java.util.stream.Stream<? extends T>-\"><T>fromStream</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>generate-java.util.function.Consumer<reactor.core.publisher.SynchronousSink<T>>-\"><T>generate</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>just-T-\"><T>just</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>just-T...-\"><T>just</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>merge-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>merge-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-\"><T>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>merge-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-int-\"><T>merge</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeComparing-int-java.util.Comparator<? super T>-org.reactivestreams.Publisher<? extends T>...-\"><T>mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeComparing-java.util.Comparator<? super T>-org.reactivestreams.Publisher<? extends T>...-\"><T>mergeComparing</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeComparingDelayError-int-java.util.Comparator<? super T>-org.reactivestreams.Publisher<? extends T>...-\"><T>mergeComparingDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeOrdered-int-java.util.Comparator<? super T>-org.reactivestreams.Publisher<? extends T>...-\"><T>mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeOrdered-java.util.Comparator<? super T>-org.reactivestreams.Publisher<? extends T>...-\"><T>mergeOrdered</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeSequential-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeSequential-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-int-\"><T>mergeSequential</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>mergeSequentialDelayError-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-int-\"><T>mergeSequentialDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>never--\"><T>never</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>onAssembly-reactor.core.publisher.ConnectableFlux<T>-\"><T>onAssembly</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>onAssembly-reactor.core.publisher.Flux<T>-\"><T>onAssembly</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>push-java.util.function.Consumer<? super reactor.core.publisher.FluxSink<T>>-\"><T>push</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>push-java.util.function.Consumer<? super reactor.core.publisher.FluxSink<T>>-reactor.core.publisher.FluxSink.OverflowStrategy-\"><T>push</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>switchOnNext-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-\"><T>switchOnNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<T>switchOnNext-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>>-int-\"><T>switchOnNext</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<TRight-TLeftEnd-TRightEnd-R>groupJoin-org.reactivestreams.Publisher<? extends TRight>-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<TLeftEnd>>-java.util.function.Function<? super TRight-? extends org.reactivestreams.Publisher<TRightEnd>>-java.util.function.BiFunction<? super T-? super reactor.core.publisher.Flux<TRight>-? extends R>-\"><TRight,TLeftEnd,TRightEnd,R>groupJoin</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<TRight-TLeftEnd-TRightEnd-R>join-org.reactivestreams.Publisher<? extends TRight>-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<TLeftEnd>>-java.util.function.Function<? super TRight-? extends org.reactivestreams.Publisher<TRightEnd>>-java.util.function.BiFunction<? super T-? super TRight-? extends R>-\"><TRight,TLeftEnd,TRightEnd,R>join</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<TUPLE-V>zip-org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<?>>-java.util.function.Function<? super TUPLE-? extends V>-\"><TUPLE,V>zip</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-R>withLatestFrom-org.reactivestreams.Publisher<? extends U>-java.util.function.BiFunction<? super T-? super U-? extends R>-\"><U,R>withLatestFrom</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-V-C>bufferWhen-org.reactivestreams.Publisher<U>-java.util.function.Function<? super U-? extends org.reactivestreams.Publisher<V>>-java.util.function.Supplier<C>-\"><U,V,C>bufferWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-V>bufferWhen-org.reactivestreams.Publisher<U>-java.util.function.Function<? super U-? extends org.reactivestreams.Publisher<V>>-\"><U,V>bufferWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-V>timeout-org.reactivestreams.Publisher<U>-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<V>>-\"><U,V>timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-V>timeout-org.reactivestreams.Publisher<U>-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<V>>-org.reactivestreams.Publisher<? extends T>-\"><U,V>timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U-V>windowWhen-org.reactivestreams.Publisher<U>-java.util.function.Function<? super U-? extends org.reactivestreams.Publisher<V>>-\"><U,V>windowWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>delaySubscription-org.reactivestreams.Publisher<U>-\"><U>delaySubscription</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>ofType-java.lang.Class<U>-\"><U>ofType</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>sample-org.reactivestreams.Publisher<U>-\"><U>sample</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>sampleFirst-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<U>>-\"><U>sampleFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>sampleTimeout-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<U>>-\"><U>sampleTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>sampleTimeout-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<U>>-int-\"><U>sampleTimeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<U>timeout-org.reactivestreams.Publisher<U>-\"><U>timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V-C>distinct-java.util.function.Function<? super T-? extends V>-java.util.function.Supplier<C>-\"><V,C>distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V-C>distinct-java.util.function.Function<? super T-? extends V>-java.util.function.Supplier<C>-java.util.function.BiPredicate<C-V>-java.util.function.Consumer<C>-\"><V,C>distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>bufferUntilChanged--\"><V>bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>bufferUntilChanged-java.util.function.Function<? super T-? extends V>-\"><V>bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>bufferUntilChanged-java.util.function.Function<? super T-? extends V>-java.util.function.BiPredicate<? super V-? super V>-\"><V>bufferUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>concatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-\"><V>concatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>concatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-int-\"><V>concatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>concatMapDelayError-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-\"><V>concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>concatMapDelayError-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-boolean-int-\"><V>concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>concatMapDelayError-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-int-\"><V>concatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>distinct-java.util.function.Function<? super T-? extends V>-\"><V>distinct</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>distinctUntilChanged-java.util.function.Function<? super T-? extends V>-\"><V>distinctUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>distinctUntilChanged-java.util.function.Function<? super T-? extends V>-java.util.function.BiPredicate<? super V-? super V>-\"><V>distinctUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>flatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-int-\"><V>flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>flatMap-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-int-int-\"><V>flatMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>flatMapDelayError-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends V>>-int-int-\"><V>flatMapDelayError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>map-java.util.function.Function<? super T-? extends V>-\"><V>map</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>mapNotNull-java.util.function.Function<? super T-? extends V>-\"><V>mapNotNull</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>switchMap-java.util.function.Function<? super T-org.reactivestreams.Publisher<? extends V>>-\"><V>switchMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>switchMap-java.util.function.Function<? super T-org.reactivestreams.Publisher<? extends V>>-int-\"><V>switchMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>switchOnFirst-java.util.function.BiFunction<reactor.core.publisher.Signal<? extends T>-reactor.core.publisher.Flux<T>-org.reactivestreams.Publisher<? extends V>>-\"><V>switchOnFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>switchOnFirst-java.util.function.BiFunction<reactor.core.publisher.Signal<? extends T>-reactor.core.publisher.Flux<T>-org.reactivestreams.Publisher<? extends V>>-boolean-\"><V>switchOnFirst</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>then-reactor.core.publisher.Mono<V>-\"><V>then</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>thenMany-org.reactivestreams.Publisher<V>-\"><V>thenMany</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>transform-java.util.function.Function<? super reactor.core.publisher.Flux<T>-? extends org.reactivestreams.Publisher<V>>-\"><V>transform</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>transformDeferred-java.util.function.Function<? super reactor.core.publisher.Flux<T>-? extends org.reactivestreams.Publisher<V>>-\"><V>transformDeferred</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>transformDeferredContextual-java.util.function.BiFunction<? super reactor.core.publisher.Flux<T>-? super reactor.util.context.ContextView-? extends org.reactivestreams.Publisher<V>>-\"><V>transformDeferredContextual</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>windowUntilChanged--\"><V>windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>windowUntilChanged-java.util.function.Function<? super T-? extends V>-java.util.function.BiPredicate<? super V-? super V>-\"><V>windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<V>windowUntilChanged-java.util.function.Function<? super T-? super V>-\"><V>windowUntilChanged</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#<X>dematerialize--\"><X>dematerialize</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#all-java.util.function.Predicate<? super T>-\">all</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#any-java.util.function.Predicate<? super T>-\">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<? super T>-\">bufferUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntil-java.util.function.Predicate<? super T>-boolean-\">bufferUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferWhile-java.util.function.Predicate<? super T>-\">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<? super T>-\">collectSortedList</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatWith-org.reactivestreams.Publisher<? extends T>-\">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<reactor.util.context.Context-reactor.util.context.Context>-\">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<? super T-? extends org.reactivestreams.Publisher<?>>-\">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<reactor.core.publisher.SignalType>-\">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<? super reactor.core.publisher.Signal<T>>-\">doOnEach</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnError-java.util.function.Consumer<? super java.lang.Throwable>-\">doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnError-java.util.function.Predicate<? super java.lang.Throwable>-java.util.function.Consumer<? super java.lang.Throwable>-\">doOnError</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doOnNext-java.util.function.Consumer<? super T>-\">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<? super org.reactivestreams.Subscription>-\">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<? super T-? extends org.reactivestreams.Publisher<? extends T>>-\">expand</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expand-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends T>>-int-\">expand</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expandDeep-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends T>>-\">expandDeep</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expandDeep-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<? extends T>>-int-\">expandDeep</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filter-java.util.function.Predicate<? super T>-\">filter</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filterWhen-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<java.lang.Boolean>>-\">filterWhen</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#filterWhen-java.util.function.Function<? super T-? extends org.reactivestreams.Publisher<java.lang.Boolean>>-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<? extends T>-java.util.Comparator<? super T>-\">mergeComparingWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeOrderedWith-org.reactivestreams.Publisher<? extends T>-java.util.Comparator<? super T>-\">mergeOrderedWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#mergeWith-org.reactivestreams.Publisher<? extends T>-\">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<? super T>-\">onBackpressureBuffer</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onBackpressureBuffer-int-java.util.function.Consumer<? super T>-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<? super T>-\">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<? super T>-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<? super T>-\">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<? extends java.lang.Throwable>-\">onErrorComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorComplete-java.util.function.Predicate<? super java.lang.Throwable>-\">onErrorComplete</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorContinue-java.util.function.BiConsumer<java.lang.Throwable-java.lang.Object>-\">onErrorContinue</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorMap-java.util.function.Function<? super java.lang.Throwable-? extends java.lang.Throwable>-\">onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorMap-java.util.function.Predicate<? super java.lang.Throwable>-java.util.function.Function<? super java.lang.Throwable-? extends java.lang.Throwable>-\">onErrorMap</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorResume-java.util.function.Function<? super java.lang.Throwable-? extends org.reactivestreams.Publisher<? extends T>>-\">onErrorResume</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#onErrorResume-java.util.function.Predicate<? super java.lang.Throwable>-java.util.function.Function<? super java.lang.Throwable-? extends org.reactivestreams.Publisher<? extends T>>-\">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<? super java.lang.Throwable>-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<? extends T>-\">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<T-T-T>-\">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<reactor.core.publisher.Flux<java.lang.Long>-? 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<T-T-T>-\">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<? super T>-\">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<? super T>-\">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<? super T>-\">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<? extends T>-\">startWith</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#startWith-org.reactivestreams.Publisher<? extends T>-\">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<? super T>-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer<? super T>-java.util.function.Consumer<? super java.lang.Throwable>-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer<? super T>-java.util.function.Consumer<? super java.lang.Throwable>-java.lang.Runnable-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer<? super T>-java.util.function.Consumer<? super java.lang.Throwable>-java.lang.Runnable-java.util.function.Consumer<? super org.reactivestreams.Subscription>-\">subscribe</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribe-java.util.function.Consumer<? super T>-java.util.function.Consumer<? super java.lang.Throwable>-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<? super T>-\">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<reactor.util.context.Context-reactor.util.context.Context>-\">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<? extends T>-\">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<? super T>-\">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<? super T>-\">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<java.lang.Void>-\">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<? extends T>-\">timeout</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#timeout-java.time.Duration-org.reactivestreams.Publisher<? extends T>-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<java.util.Queue<T>>-\">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<T>-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntil-java.util.function.Predicate<T>-boolean-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowUntil-java.util.function.Predicate<T>-boolean-int-\">windowUntil</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowWhile-java.util.function.Predicate<T>-\">windowWhile</a>"
  - "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#windowWhile-java.util.function.Predicate<T>-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>.<S>mapPage(Function<T,S> mapper)"
  name: "<S>mapPage(Function<T,S> mapper)"
  nameWithType: "PagedFlux<T>.<S>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>.<T>create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  name: "<T>create(Supplier<PageRetriever<String,PagedResponse<T>>> provider)"
  nameWithType: "PagedFlux<T>.<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.34.0