cyclops.function

Class FluentFunctions.FluentRunnable<R>

java.lang.Object

cyclops.function.FluentFunctions.FluentRunnable<R>

All Implemented Interfaces:

Effect, java.lang.Runnable

Enclosing class:

FluentFunctions

public static class FluentFunctions.FluentRunnable<R>
extends java.lang.Object
implements Effect

Constructor Summary

Constructors

Constructor and Description
FluentRunnable(java.lang.Runnable fn)

Method Summary

Modifier and Type	Method and Description
FluentFunctions.FluentRunnable	after(java.lang.Runnable action) Apply after advice to this Supplier
FluentFunctions.FluentRunnable	around(java.util.function.Function<FluentFunctions.Advice0<java.lang.Void>,java.lang.Void> around) Apply around advice to this Supplier
FluentFunctions.FluentRunnable<R>	before(java.lang.Runnable r) Apply before advice to this Supplier
FluentFunctions.FluentRunnable	log(java.util.function.Consumer<java.lang.String> logger, java.util.function.Consumer<java.lang.Throwable> error) A supplier that logs it's success or error states to the provided Consumers
FluentFunctions.FluentRunnable	memoize()
FluentFunctions.FluentRunnable	name(java.lang.String name)
FluentFunctions.FluentRunnable	println()
<X extends java.lang.Throwable> FluentFunctions.FluentRunnable	recover(java.lang.Class<X> type, java.util.function.Supplier<R> onError) A supplier that can recover from the specified exception types, using the provided Supplier
FluentFunctions.FluentRunnable	retry(int times, int backoffStartTime) A supplier capable of retrying on failure using an exponential backoff strategy
void	run()
void	runChecked()

Methods inherited from class java.lang.Object

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

Methods inherited from interface cyclops.function.Effect

andThen, andThenChecked, async, asyncAndBlock, callable, compose, composeChecked, cycle, cycle, cycleAsync, cycleAsync, cycleForever, cycleUntil, cycleUntilException, cycleWhile, flatMap, fluentRunnable, forEach2, forEach3, forEach4, future, noop, onError, retry, retry, runAsync, supply, supplyOr, visit

Constructor Detail

FluentRunnable

public FluentRunnable(java.lang.Runnable fn)

Method Detail

before

public FluentFunctions.FluentRunnable<R> before(java.lang.Runnable r)

Apply before advice to this Supplier

Parameters:

r - Runnable that represents before advice (AOP)

Returns:

Returns a new Supplier with before advice attached

after

public FluentFunctions.FluentRunnable after(java.lang.Runnable action)

Apply after advice to this Supplier

Parameters:

action - Runnable that represents after advice (AOP)

Returns:

Returns a new Supplier with after advice attached

around

public FluentFunctions.FluentRunnable around(java.util.function.Function<FluentFunctions.Advice0<java.lang.Void>,java.lang.Void> around)

Apply around advice to this Supplier

Parameters:

around - Function that captures input to this Supplier and can optionally pass on the call

Returns:

Supplier with around advice attached

memoize

public FluentFunctions.FluentRunnable memoize()

Specified by:

memoize in interface Effect

Returns:

A caching version of this Supplier

name

public FluentFunctions.FluentRunnable name(java.lang.String name)

Parameters:

name - To give this supplier

Returns:

A supplier with a name (useful for logging purposes)

println

public FluentFunctions.FluentRunnable println()

Returns:

A supplier that prints out it's result or error on failure

log

public FluentFunctions.FluentRunnable log(java.util.function.Consumer<java.lang.String> logger,
                                          java.util.function.Consumer<java.lang.Throwable> error)

A supplier that logs it's success or error states to the provided Consumers

Parameters:

logger - Success logger

error - Failure logger

Returns:

Supplier that logs it's state

recover

public <X extends java.lang.Throwable> FluentFunctions.FluentRunnable recover(java.lang.Class<X> type,
                                                                              java.util.function.Supplier<R> onError)

A supplier that can recover from the specified exception types, using the provided Supplier

Parameters:

type - Recoverable exception types

onError - Supplier to use on error

Returns:

Supplier capable of error recovery

retry

public FluentFunctions.FluentRunnable retry(int times,
                                            int backoffStartTime)

A supplier capable of retrying on failure using an exponential backoff strategy

Parameters:

times - Number of times to retry

backoffStartTime - Wait time before first retry

Returns:

Supplier with a retry strategy

run

public void run()

Specified by:

run in interface Effect

Specified by:

run in interface java.lang.Runnable

runChecked

public void runChecked()
                throws java.lang.Exception

Specified by:

runChecked in interface Effect

Throws:

java.lang.Exception