Package org.apache.juneau.rest.server.reactive.reactor

Class ReactorReactiveAdapter

java.lang.Object

org.apache.juneau.rest.server.reactive.reactor.ReactorReactiveAdapter

All Implemented Interfaces:

ReactiveStreamsAdapter

public class ReactorReactiveAdapter
extends Object
implements ReactiveStreamsAdapter

ReactiveStreamsAdapter for Project Reactor return types.

• Mono<T> → single value (via Mono.toFuture()). An empty Mono completes the response with a null body.
• Flux<T> → stream (via FlowAdapters.toFlowPublisher(Publisher)).

Registered ahead of ReactiveStreamsPublisherAdapter so a Mono (which also implements org.reactivestreams.Publisher) is treated as a single value rather than a one-element stream.

Since:

10.0.0

Constructor Summary

Constructors

Constructor	Description
ReactorReactiveAdapter()

Method Summary

Modifier and Type	Method	Description
Adaptation	adapt(Object value)	Converts the supplied reactive value to a JDK-native Adaptation.
boolean	canAdapt(Object value)	Returns whether this adapter recognizes the supplied return value.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactorReactiveAdapter

public ReactorReactiveAdapter()

Method Details

canAdapt

public boolean canAdapt(Object value)

Description copied from interface: ReactiveStreamsAdapter

Returns whether this adapter recognizes the supplied return value.

Implementations must return false (rather than throw) for values they do not handle, and must be cheap to call — this is invoked on the response hot path for every non-null handler return value once at least one adapter is registered.

Specified by:

canAdapt in interface ReactiveStreamsAdapter

Parameters:

value - The @RestOp handler return value. Never null.

Returns:

true if ReactiveStreamsAdapter.adapt(Object) can convert this value.

adapt

public Adaptation adapt(Object value)

Description copied from interface: ReactiveStreamsAdapter

Converts the supplied reactive value to a JDK-native Adaptation.

Only called when ReactiveStreamsAdapter.canAdapt(Object) returned true for the same value.

Specified by:

adapt in interface ReactiveStreamsAdapter

Parameters:

value - The reactive value to adapt. Never null.

Returns:

The adapted single-value or streaming shape. Never null.