Package com.shri.restinpeace.reactor
package com.shri.restinpeace.reactor
-
ClassesClassDescriptionClaims a plain (non-
@Paginated)Flux<T>-returning@RestClientmethod - "flavor 1" ofFlux<T>support (§7.1): decodes the response body asList<T>(RIP's existing generic-collection decoding, E9/E12) then emits it item-by-item viaFlux.fromIterable(java.lang.Iterable<? extends T>).Claims a@Paginatedmethod returningFlux<T>- "flavor 2" ofFlux<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 alongsidePage<T>(manual) andStream<T>/Iterator<T>(eager-per-item-pull, lazy-per-page).Claims everyMono<T>-returning@RestClientmethod -Mono<Void>,Mono<RipResponse<T>>, andMono<byte[]>all work identically, sinceresponseBodyType()just namesTverbatim andRequestExecutor's existing dispatch already handles every one of those shapes for anyCallAdapter.Entry point forrest-in-peace-reactor: registers this module'sCallAdapter/PaginatedCallAdapterfactories with RIP.