Package org.springframework.graphql.execution

Class ReactiveAdapterRegistryHelper

java.lang.Object

org.springframework.graphql.execution.ReactiveAdapterRegistryHelper

public abstract class ReactiveAdapterRegistryHelper
extends Object

Helper to adapt a result Object to Mono or Flux through ReactiveAdapterRegistry.

Since:

1.3.1

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor	Description
ReactiveAdapterRegistryHelper()

Method Summary

Modifier and Type	Method	Description
static <T> reactor.core.publisher.Flux<T>	toFluxFromCollection(Object result)	Return a Flux for the given result Object that represents a logical collection of values.
static <T> reactor.core.publisher.Mono<T>	toMono(Object result)	Return a Mono for the given Object by delegating to toMonoIfReactive(java.lang.Object), and then applying Mono.justOrEmpty(java.util.Optional<? extends T>) if necessary.
static Object	toMonoIfReactive(Object result)	Return a Mono for the given result Object if it can be adapted to a Publisher via ReactiveAdapterRegistry.
static Object	toMonoOrFluxIfReactive(Object result)	Adapt the given result Object to Mono or Flux if it can be adapted to a single or multi-value Publisher respectively via ReactiveAdapterRegistry.
static reactor.core.publisher.Flux<?>	toSubscriptionFlux(Object result)	Return a Flux for the given result Object, adapting to a Publisher first if necessary via ReactiveAdapterRegistry.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveAdapterRegistryHelper

public ReactiveAdapterRegistryHelper()

Method Details

toMono

public static <T> reactor.core.publisher.Mono<T> toMono(@Nullable
 Object result)

Return a Mono for the given Object by delegating to toMonoIfReactive(java.lang.Object), and then applying Mono.justOrEmpty(java.util.Optional<? extends T>) if necessary.

Type Parameters:

T - the type of element in the Mono to cast to

Parameters:

result - the result Object to adapt

Returns:

a Mono that represents the result

toMonoIfReactive

@Nullable
public static Object toMonoIfReactive(@Nullable
 Object result)

Return a Mono for the given result Object if it can be adapted to a Publisher via ReactiveAdapterRegistry. Multivalued publishers are collected to a List.

Parameters:

result - the result Object to adapt

Returns:

the same instance or a Mono if the object is known to ReactiveAdapterRegistry

toMonoOrFluxIfReactive

@Nullable
public static Object toMonoOrFluxIfReactive(@Nullable
 Object result)

Adapt the given result Object to Mono or Flux if it can be adapted to a single or multi-value Publisher respectively via ReactiveAdapterRegistry.

Parameters:

result - the result Object to adapt

Returns:

the same instance, a Mono, or a Flux

toSubscriptionFlux

public static reactor.core.publisher.Flux<?> toSubscriptionFlux(@Nullable
 Object result)

Return a Flux for the given result Object, adapting to a Publisher first if necessary via ReactiveAdapterRegistry.

Parameters:

result - the result Object to adapt

Returns:

a Flux, possibly empty if the result is null

toFluxFromCollection

public static <T> reactor.core.publisher.Flux<T> toFluxFromCollection(@Nullable
 Object result)

Return a Flux for the given result Object that represents a logical collection of values. The Object must be a Collection or a publisher of a Collection, which is flattened with Flux.fromIterable(Iterable), or a multi-value publisher.

Type Parameters:

T - the type of element in the collection to cast to

Parameters:

result - the result Object to adapt

Returns:

a Flux that represents the collection