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

Class ReactiveStreamsPublisherAdapter

java.lang.Object

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

All Implemented Interfaces:

ReactiveStreamsAdapter

public class ReactiveStreamsPublisherAdapter
extends Object
implements ReactiveStreamsAdapter

Catch-all ReactiveStreamsAdapter for any Reactive-Streams org.reactivestreams.Publisher<T> that is not already handled by a more specific adapter.

Converts to a JDK Flow.Publisher via FlowAdapters.toFlowPublisher(Publisher) and renders it as a stream. Registered last so library-specific single-value types (Reactor Mono, which also implements Publisher) are matched by their own adapter first.

Since:

10.0.0

Constructor Summary

Constructors

Constructor	Description
ReactiveStreamsPublisherAdapter()

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

ReactiveStreamsPublisherAdapter

public ReactiveStreamsPublisherAdapter()

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.