cyclops.function

Interface Effect

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

FluentFunctions.FluentRunnable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface Effect
extends java.lang.Runnable

Method Summary

Modifier and Type	Method and Description
default Effect	andThen(java.lang.Runnable r)
default Effect	andThenChecked(java.util.concurrent.Callable<java.lang.Void> r)
default Effect	async(java.util.concurrent.Executor ex)
default Effect	asyncAndBlock(java.util.concurrent.Executor ex)
default java.util.concurrent.Callable<java.lang.Void>	callable()
default Effect	compose(java.lang.Runnable r)
default Effect	composeChecked(java.util.concurrent.Callable<java.lang.Void> r)
default Effect	cycle()
default Effect	cycle(long times)
default Effect	cycleAsync(java.util.concurrent.Executor ex)
default Effect	cycleAsync(long times, java.util.concurrent.Executor ex)
default Effect	cycleForever(java.util.function.Consumer<java.lang.Throwable> onError)
default Effect	cycleUntil(java.util.function.Supplier<java.lang.Boolean> pred)
default Effect	cycleUntilException(java.util.function.Consumer<java.lang.Throwable> onError)
default Effect	cycleWhile(java.util.function.Supplier<java.lang.Boolean> pred)
default Effect	flatMap(java.util.function.Supplier<java.lang.Runnable> r)
default FluentFunctions.FluentRunnable	fluentRunnable()
default <R1,R4> Effect	forEach2(java.util.function.Supplier<Effect> value2, Effect yieldingFunction)
default <R1,R4> Effect	forEach3(java.util.function.Supplier<Effect> value2, java.util.function.Supplier<Effect> value3, Effect yieldingFunction)
default <R1,R4> Effect	forEach4(java.util.function.Supplier<Effect> value2, java.util.function.Supplier<Effect> value3, java.util.function.Supplier<Effect> value4, Effect yieldingFunction)
default Future<java.lang.Void>	future(java.util.concurrent.Executor ex)
default Effect	memoize()
default Effect	noop()
default Effect	onError(java.util.function.Consumer<java.lang.Throwable> onError)
default Effect	retry()
default Effect	retry(int retries, long delay, java.util.concurrent.TimeUnit timeUnit)
default void	run()
default java.lang.Thread	runAsync()
void	runChecked()
default <R> Fn0<R>	supply(R r)
default <R> Fn0<R>	supplyOr(R success, R failure)
default <R> R	visit(java.util.function.Supplier<R> success, java.util.function.Function<java.lang.Throwable,? extends R> failure)

Method Detail

memoize

default Effect memoize()

runAsync

default java.lang.Thread runAsync()

future

default Future<java.lang.Void> future(java.util.concurrent.Executor ex)

async

default Effect async(java.util.concurrent.Executor ex)

asyncAndBlock

default Effect asyncAndBlock(java.util.concurrent.Executor ex)

run

default void run()

Specified by:

run in interface java.lang.Runnable

callable

default java.util.concurrent.Callable<java.lang.Void> callable()

runChecked

void runChecked()
         throws java.lang.Exception

Throws:

java.lang.Exception

onError

default Effect onError(java.util.function.Consumer<java.lang.Throwable> onError)

andThen

default Effect andThen(java.lang.Runnable r)

andThenChecked

default Effect andThenChecked(java.util.concurrent.Callable<java.lang.Void> r)

supply

default <R> Fn0<R> supply(R r)

visit

default <R> R visit(java.util.function.Supplier<R> success,
                    java.util.function.Function<java.lang.Throwable,? extends R> failure)

supplyOr

default <R> Fn0<R> supplyOr(R success,
                            R failure)

flatMap

default Effect flatMap(java.util.function.Supplier<java.lang.Runnable> r)

noop

default Effect noop()

cycle

default Effect cycle()

cycleAsync

default Effect cycleAsync(java.util.concurrent.Executor ex)

cycleAsync

default Effect cycleAsync(long times,
                          java.util.concurrent.Executor ex)

cycleForever

default Effect cycleForever(java.util.function.Consumer<java.lang.Throwable> onError)

cycle

default Effect cycle(long times)

cycleWhile

default Effect cycleWhile(java.util.function.Supplier<java.lang.Boolean> pred)

cycleUntil

default Effect cycleUntil(java.util.function.Supplier<java.lang.Boolean> pred)

cycleUntilException

default Effect cycleUntilException(java.util.function.Consumer<java.lang.Throwable> onError)

fluentRunnable

default FluentFunctions.FluentRunnable fluentRunnable()

retry

default Effect retry()

retry

default Effect retry(int retries,
                     long delay,
                     java.util.concurrent.TimeUnit timeUnit)

Parameters:

retries - Number of retries

delay - Delay in TimeUnits

timeUnit - TimeUnit to use for delay

compose

default Effect compose(java.lang.Runnable r)

composeChecked

default Effect composeChecked(java.util.concurrent.Callable<java.lang.Void> r)

forEach4

default <R1,R4> Effect forEach4(java.util.function.Supplier<Effect> value2,
                                java.util.function.Supplier<Effect> value3,
                                java.util.function.Supplier<Effect> value4,
                                Effect yieldingFunction)

forEach3

default <R1,R4> Effect forEach3(java.util.function.Supplier<Effect> value2,
                                java.util.function.Supplier<Effect> value3,
                                Effect yieldingFunction)

forEach2

default <R1,R4> Effect forEach2(java.util.function.Supplier<Effect> value2,
                                Effect yieldingFunction)