Class MonoHandler

java.lang.Object

org.springframework.amqp.utils.MonoHandler

public final class MonoHandler
extends Object

Class to prevent direct links to Mono.

Since:

4.1

Author:

Gary Russell, Artem Bilan, Arnab Nandy

Method Summary

Modifier and Type	Method	Description
static boolean	isMono(@Nullable Object result)
static boolean	isMono(Class<?> resultType)
static void	subscribe(Object returnValue, @Nullable Consumer<? super Object> success, Consumer<? super Throwable> failure, Runnable completeConsumer)
static CompletableFuture<?>	toCompletableFuture(Object returnValue)	Convert a Mono to a CompletableFuture.

Methods inherited from class Object

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

Method Details

isMono

public static boolean isMono(@Nullable Object result)

isMono

public static boolean isMono(Class<?> resultType)

subscribe

public static void subscribe(Object returnValue,
 @Nullable Consumer<? super Object> success,
 Consumer<? super Throwable> failure,
 Runnable completeConsumer)

toCompletableFuture

public static CompletableFuture<?> toCompletableFuture(Object returnValue)

Convert a Mono to a CompletableFuture.

Parameters:

returnValue - the return value (expected to be a Mono)

Returns:

the CompletableFuture

Since:

4.2