hu.akarnokd.reactive4java.util

Class RunOnce

java.lang.Object

hu.akarnokd.reactive4java.util.RunOnce

public final class RunOnce
extends java.lang.Object

Helper class which ensures that only a single action is invoked. It can be used in cases when multiple observers want to do the same thing (e.g., fire an error() or finish()) but only one of them should ever succeed

Constructor Summary

Constructors

Constructor and Description
RunOnce()

Method Summary

Modifier and Type	Method and Description
boolean	invoke(Action0 action) Invoke the given action only if this RunOnce has not invoked anything before.
<T> boolean	invoke(Action1<? super T> action, T parameter) Invoke the given action only if this RunOnce has not invoked anything before.

Methods inherited from class java.lang.Object

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

Constructor Detail

RunOnce

public RunOnce()

Method Detail

invoke

public boolean invoke(Action0 action)

Invoke the given action only if this RunOnce has not invoked anything before. The method ensures that if this RunOnce is invoked from multiple threads or multiple cases, only the very first one executes its submitted action.

Parameters:

action - the action to invoke

Returns:

returns true if the action was invoked

invoke

public <T> boolean invoke(Action1<? super T> action,
                          T parameter)

Invoke the given action only if this RunOnce has not invoked anything before. The method ensures that if this RunOnce is invoked from multiple threads or multiple cases, only the very first one executes its submitted action.

Type Parameters:

T - the parameter type

Parameters:

action - the action to invoke

parameter - the parameter to use when invoking the action.

Returns:

true if the action was invoked