Package net.officefloor.reactor

Class FluxSubscription<T>

java.lang.Object

net.officefloor.reactor.AbstractSubscription<T>

net.officefloor.reactor.FluxSubscription<T>

public class FluxSubscription<T>
extends AbstractSubscription<T>

Flux subscription.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
FluxSubscription(java.lang.Class<?> comonentType, ManagedFunctionContext<?,?> context)	Instantiate.

Method Summary

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

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 Detail

FluxSubscription

public FluxSubscription(java.lang.Class<?> comonentType,
                        ManagedFunctionContext<?,?> context)

Instantiate.

Parameters:

context - ManagedFunctionContext.

Method Detail

subscribe

public static <T> void subscribe(java.lang.Class<?> componentType,
                                 reactor.core.publisher.Flux<T> flux,
                                 ManagedFunctionContext<?,?> context)

Subscribes to the Flux.

Type Parameters:

T - Success type.

Parameters:

componentType - Component type for success array.

flux - Flux.

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 java.lang.Object getNextFunctionArgument()

Description copied from class: AbstractSubscription

Obtains the next ManagedFunction argument.

Specified by:

getNextFunctionArgument in class AbstractSubscription<T>

Returns:

Next ManagedFunction argument.