Package org.apache.groovy.rxjava

Class RxJavaAwaitableAdapter

java.lang.Object

org.apache.groovy.rxjava.RxJavaAwaitableAdapter

All Implemented Interfaces:

AwaitableAdapter

public class RxJavaAwaitableAdapter
extends Object
implements AwaitableAdapter

Adapter for RxJava 3 types, enabling:

• await single — awaits a Single
• await maybe — awaits a Maybe (nullable result)
• await completable — awaits a Completable
• for await (item in observable) — iterates over an Observable
• for await (item in flowable) — iterates over a Flowable

Auto-discovered via ServiceLoader when groovy-rxjava is on the classpath.

Since:

6.0.0

Constructor Summary

Constructors

Constructor	Description
RxJavaAwaitableAdapter()

Method Summary

Modifier and Type	Method	Description
boolean	supportsAwaitable(Class<?> type)	Returns true if this adapter can convert instances of the given type to Awaitable (single-value async result).
boolean	supportsIterable(Class<?> type)	Returns true if this adapter can convert instances of the given type to an Iterable for for await loops.
<T> Awaitable<T>	toAwaitable(Object source)	Converts the given source object to an Awaitable.
<T> Iterable<T>	toIterable(Object source)	Converts the given source object to an Iterable.

Methods inherited from class java.lang.Object

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

Constructor Details

RxJavaAwaitableAdapter

public RxJavaAwaitableAdapter()

Method Details

supportsAwaitable

public boolean supportsAwaitable(Class<?> type)

Description copied from interface: AwaitableAdapter

Returns true if this adapter can convert instances of the given type to Awaitable (single-value async result).

Specified by:

supportsAwaitable in interface AwaitableAdapter

toAwaitable

public <T> Awaitable<T> toAwaitable(Object source)

Description copied from interface: AwaitableAdapter

Converts the given source object to an Awaitable. Called only when AwaitableAdapter.supportsAwaitable(java.lang.Class<?>) returned true.

Specified by:

toAwaitable in interface AwaitableAdapter

supportsIterable

public boolean supportsIterable(Class<?> type)

Description copied from interface: AwaitableAdapter

Returns true if this adapter can convert instances of the given type to an Iterable for for await loops. Defaults to false; override for multi-value async types (e.g., Reactor Flux, RxJava Observable).

Specified by:

supportsIterable in interface AwaitableAdapter

toIterable

public <T> Iterable<T> toIterable(Object source)

Description copied from interface: AwaitableAdapter

Converts the given source object to an Iterable. Called only when AwaitableAdapter.supportsIterable(java.lang.Class<?>) returned true. The returned iterable typically blocks on next() until the next element is available — with virtual threads this is efficient.

Specified by:

toIterable in interface AwaitableAdapter