Package net.officefloor.reactor

Class MonoSubscription<T>

java.lang.Object

net.officefloor.reactor.AbstractSubscription<T>

net.officefloor.reactor.MonoSubscription<T>

public class MonoSubscription<T>
extends AbstractSubscription<T>

Mono subscription.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
MonoSubscription(ManagedFunctionContext<?,?> context)	Instantiate.

Method Summary

Modifier and Type	Method	Description
protected void	addSuccess(T success)	Adds the success.
protected Object	getNextFunctionArgument()	Obtains the next ManagedFunction argument.
static <T> void	subscribe(reactor.core.publisher.Mono<T> mono, ManagedFunctionContext<?,?> context)	Subscribes to the Mono.

Methods inherited from class net.officefloor.reactor.AbstractSubscription

getCompletion, getError, getSuccess

Methods inherited from class java.lang.Object

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

Constructor Details

MonoSubscription

public MonoSubscription(ManagedFunctionContext<?,?> context)

Instantiate.

Parameters:

context - ManagedFunctionContext.

Method Details

subscribe

public static <T> void subscribe(reactor.core.publisher.Mono<T> mono,
 ManagedFunctionContext<?,?> context)

Subscribes to the Mono.

Type Parameters:

T - Success type.

Parameters:

mono - Mono.

context - ManagedFunctionContext.

addSuccess

protected void addSuccess(T success)

Description copied from class: AbstractSubscription

Adds the success.

Specified by:

addSuccess in class AbstractSubscription<T>

Parameters:

success - Success.

getNextFunctionArgument

protected Object getNextFunctionArgument()

Description copied from class: AbstractSubscription

Obtains the next ManagedFunction argument.

Specified by:

getNextFunctionArgument in class AbstractSubscription<T>

Returns:

Next ManagedFunction argument.