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

Class RxJavaReactiveAdapter

java.lang.Object

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

All Implemented Interfaces:

ReactiveStreamsAdapter

public class RxJavaReactiveAdapter
extends Object
implements ReactiveStreamsAdapter

ReactiveStreamsAdapter for RxJava 3 return types.

• Single<T> → single value (via Single.toCompletionStage()).
• Maybe<T> → single value (via Maybe.toCompletionStage(Object) with a null default, so an empty Maybe yields a null body).
• Completable → single null value (via Completable.toCompletionStage(Object)).
• Flowable<T> → stream (via FlowAdapters.toFlowPublisher(Publisher)).
• Observable<T> → stream (converted to a Flowable with BackpressureStrategy.BUFFER first, since Observable has no native backpressure).

Since:

10.0.0

Constructor Summary

Constructors

Constructor	Description
RxJavaReactiveAdapter()

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

RxJavaReactiveAdapter

public RxJavaReactiveAdapter()

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.