org.openecomp.sdc.common.datastructure

Class FunctionalInterfaces

java.lang.Object

org.openecomp.sdc.common.datastructure.FunctionalInterfaces

public class FunctionalInterfaces
extends Object

Class For Functional interfaces And Functional Methods

Author:

mshitrit

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FunctionalInterfaces.ConsumerThrows<T,E extends Exception>
static interface	FunctionalInterfaces.ConsumerTwoParam<T1,T2>
static interface	FunctionalInterfaces.FunctionThrows<T,R,E extends Exception>
static interface	FunctionalInterfaces.FunctionTwoParam<T1,T2,R>
static interface	FunctionalInterfaces.RunnableThrows<E extends Exception>
static interface	FunctionalInterfaces.SupplierThrows<R,E extends Exception>

Constructor Summary

Constructors

Constructor and Description
FunctionalInterfaces()

Method Summary

Modifier and Type	Method and Description
static void	retryMethodOnException(Runnable methodToRun) Runs the given method. In case exception occurred runs the method again either until succeed or until 10 seconds pass.
static <R> R	retryMethodOnException(Supplier<R> methodToRun) Runs the given method. In case exception occurred runs the method again either until succeed or until 10 seconds pass.
static <R> R	retryMethodOnResult(Supplier<R> methodToRun, Function<R,Boolean> resultVerifier) Runs the given method. Verify the method result against the resultVerifier. If verification passed returns the result. If Verification failed keeps retrying until it passes or until 10 seconds pass. If Exception Occurred keeps retrying until it passes or until 10 seconds pass, If last retry result caused an exception - it is thrown.
static <R> R	retryMethodOnResult(Supplier<R> methodToRun, Function<R,Boolean> resultVerifier, long maxWaitMS, long retryIntervalMS) Runs the given method. Verify the method result against the resultVerifier. If verification passed returns the result. If Verification failed keeps retrying until it passes or until maxWait pass. If Exception Occurred keeps retrying until it passes or until maxWait pass, If last retry result caused an exception - it is thrown.
static void	sleep(long millis) Same as Thread.sleep but throws a FunctionalAttException (RuntimeException) instead of InterruptedException.
static <E extends Exception> void	swallowException(FunctionalInterfaces.RunnableThrows<E> methodToRun) Runs a method that declares throwing an Exception without return value.
static <R,E extends Exception> R	swallowException(FunctionalInterfaces.SupplierThrows<R,E> methodToRun) Runs a method that declares throwing an Exception and has a return value.

Methods inherited from class java.lang.Object

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

Constructor Detail

FunctionalInterfaces

public FunctionalInterfaces()

Method Detail

swallowException

public static <R,E extends Exception> R swallowException(FunctionalInterfaces.SupplierThrows<R,E> methodToRun)

Runs a method that declares throwing an Exception and has a return value.
In case Exception Occurred replaces it with FunctionalAttException.
This is useful for two cases:
1.using methods that throws exceptions in streams.
2.replacing declared exception with undeclared exception (Runtime).
See below Use Case:
Instead of: intList.stream().map(e -> fooThrowsAndReturnsBoolean(e)); - does not compile !
Use This : intList.stream().map(e -> swallowException( () -> fooThrowsAndReturnsBoolean(e))); - compiles !

Parameters:

methodToRun -

Returns:

swallowException

public static <E extends Exception> void swallowException(FunctionalInterfaces.RunnableThrows<E> methodToRun)

Runs a method that declares throwing an Exception without return value.
In case Exception Occurred replaces it with FunctionalAttException.
This is useful for two cases:
1.using methods that throws exceptions in streams.
2.replacing declared exception with undeclared exception (Runtime).
See below Use Case:

Parameters:

methodToRun -

retryMethodOnResult

public static <R> R retryMethodOnResult(Supplier<R> methodToRun,
                                        Function<R,Boolean> resultVerifier)

Runs the given method.
Verify the method result against the resultVerifier.
If verification passed returns the result.
If Verification failed keeps retrying until it passes or until 10 seconds pass.
If Exception Occurred keeps retrying until it passes or until 10 seconds pass,
If last retry result caused an exception - it is thrown.

Parameters:

methodToRun - given Method

resultVerifier - verifier for the method result

Returns:

retryMethodOnResult

public static <R> R retryMethodOnResult(Supplier<R> methodToRun,
                                        Function<R,Boolean> resultVerifier,
                                        long maxWaitMS,
                                        long retryIntervalMS)

Runs the given method.
Verify the method result against the resultVerifier.
If verification passed returns the result.
If Verification failed keeps retrying until it passes or until maxWait pass.
If Exception Occurred keeps retrying until it passes or until maxWait pass,
If last retry result caused an exception - it is thrown.

Parameters:

methodToRun - given Method

resultVerifier - verifier for the method result

maxWaitMS -

retryIntervalMS -

Returns:

retryMethodOnException

public static <R> R retryMethodOnException(Supplier<R> methodToRun)

Runs the given method.
In case exception occurred runs the method again either until succeed or until 10 seconds pass.

Parameters:

methodToRun - given method

Returns:

retryMethodOnException

public static void retryMethodOnException(Runnable methodToRun)

Runs the given method.
In case exception occurred runs the method again either until succeed or until 10 seconds pass.

Parameters:

methodToRun - given method

sleep

public static void sleep(long millis)

Same as Thread.sleep but throws a FunctionalAttException (RuntimeException) instead of InterruptedException.

Parameters:

millis -