Package net.officefloor.reactor

Class AbstractSubscription<T>

java.lang.Object

net.officefloor.reactor.AbstractSubscription<T>

Direct Known Subclasses:

FluxSubscription, MonoSubscription

public abstract class AbstractSubscription<T>
extends Object

Abstract MethodReturnTranslator.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected abstract void	addSuccess(T success)	Adds the success.
Runnable	getCompletion()	Obtains the completion.
Consumer<? super Throwable>	getError()	Obtain the error Consumer.
protected abstract Object	getNextFunctionArgument()	Obtains the next ManagedFunction argument.
Consumer<? super T>	getSuccess()	Obtains the success Consumer.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractSubscription

public AbstractSubscription(ManagedFunctionContext<?,?> context)

Instantiate.

Parameters:

context - ManagedFunctionContext.

Method Details

addSuccess

protected abstract void addSuccess(T success)

Adds the success.

Parameters:

success - Success.

getNextFunctionArgument

protected abstract Object getNextFunctionArgument()

Obtains the next ManagedFunction argument.

Returns:

Next ManagedFunction argument.

getSuccess

public Consumer<? super T> getSuccess()

Obtains the success Consumer.

Returns:

Success Consumer.

getError

public Consumer<? super Throwable> getError()

Obtain the error Consumer.

Returns:

Error Consumer.

getCompletion

public Runnable getCompletion()

Obtains the completion.

Returns:

Completion.