Package com.shri.restinpeace.reactor

Class FluxPaginatedCallAdapterFactory

java.lang.Object

com.shri.restinpeace.reactor.FluxPaginatedCallAdapterFactory

All Implemented Interfaces:

PaginatedCallAdapterFactory

public final class FluxPaginatedCallAdapterFactory
extends Object
implements PaginatedCallAdapterFactory

Claims a @Paginated method returning Flux<T> - "flavor 2" of Flux<T> support (§7.2), and the actually novel one: a genuinely backpressure-aware stream over @Paginated's existing page-fetch machinery, a third return-type-driven flattening mode alongside Page<T> (manual) and Stream<T>/Iterator<T> (eager-per-item-pull, lazy-per-page). RequestExecutor only ever consults this factory for a method actually annotated @Paginated (see docs/design/reactor-call-adapter.md §7.3's disambiguation), so there's no need to re-check that here.

Constructor Summary

Constructors

Constructor	Description
FluxPaginatedCallAdapterFactory()

Method Summary

Modifier and Type	Method	Description
Optional<PaginatedCallAdapter<?>>	get(Method method)

Methods inherited from class java.lang.Object

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

Constructor Details

FluxPaginatedCallAdapterFactory

public FluxPaginatedCallAdapterFactory()

Method Details

get

public Optional<PaginatedCallAdapter<?>> get(Method method)

Specified by:

get in interface PaginatedCallAdapterFactory