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 java.lang.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.
java.lang.Runnable	getCompletion()	Obtains the completion.
java.util.function.Consumer<? super java.lang.Throwable>	getError()	Obtain the error Consumer.
protected abstract java.lang.Object	getNextFunctionArgument()	Obtains the next ManagedFunction argument.
java.util.function.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 Detail

AbstractSubscription

public AbstractSubscription(ManagedFunctionContext<?,?> context)

Instantiate.

Parameters:

context - ManagedFunctionContext.

Method Detail

addSuccess

protected abstract void addSuccess(T success)

Adds the success.

Parameters:

success - Success.

getNextFunctionArgument

protected abstract java.lang.Object getNextFunctionArgument()

Obtains the next ManagedFunction argument.

Returns:

Next ManagedFunction argument.

getSuccess

public java.util.function.Consumer<? super T> getSuccess()

Obtains the success Consumer.

Returns:

Success Consumer.

getError

public java.util.function.Consumer<? super java.lang.Throwable> getError()

Obtain the error Consumer.

Returns:

Error Consumer.

getCompletion

public java.lang.Runnable getCompletion()

Obtains the completion.

Returns:

Completion.