Package org.apache.groovy.reactor

Class ReactorAwaitableAdapter

java.lang.Object

org.apache.groovy.reactor.ReactorAwaitableAdapter

All Implemented Interfaces:

AwaitableAdapter

public class ReactorAwaitableAdapter
extends Object
implements AwaitableAdapter

Adapter for Project Reactor types, enabling:

• await mono — awaits a single-value Mono
• for await (item in flux) — iterates over a Flux

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

Since:

6.0.0

Constructor Summary

Constructors

Constructor	Description
ReactorAwaitableAdapter()

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

ReactorAwaitableAdapter

public ReactorAwaitableAdapter()

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