Package io.fluxcapacitor.common

Class ObjectUtils

java.lang.Object

io.fluxcapacitor.common.ObjectUtils

public class ObjectUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
ObjectUtils()

Method Summary

Modifier and Type	Method	Description
static Callable<?>	asCallable(ThrowingRunnable runnable)
static <T> Consumer<T>	asConsumer(ThrowingConsumer<T> consumer)
static <T, R> Function<T,R>	asFunction(ThrowingFunction<T,R> function)
static Properties	asProperties(String content)
static Runnable	asRunnable(ThrowingRunnable runnable)
static Runnable	asRunnable(Callable<?> callable)
static Stream<?>	asStream(Object value)
static <T> Supplier<T>	asSupplier(Callable<T> callable)
static <T> T	call(Callable<T> callable)
static <T> Stream<T>	concat(Stream<? extends T>... streams)
static Properties	copyOf(Properties properties)
static <T> List<T>	deduplicate(List<T> list)
static <T> List<T>	deduplicate(List<T> list, Function<T,?> idFunction)
static <T> List<T>	deduplicate(List<T> list, Function<T,?> idFunction, boolean keepFirst)
static <T> Predicate<T>	distinctByKey(Function<? super T,?> keyExtractor)
static Object	forceThrow(Throwable error)
static byte[]	getBytes(ByteBuffer buffer)
static Consumer<Runnable>	ifTrue(boolean check)
static <T> Stream<T>	iterate(T seed, UnaryOperator<T> f, Predicate<T> breakCondition)
static <T, U, R> MemoizingBiFunction<T,U,R>	memoize(BiFunction<T,U,R> supplier)
static <K, V> MemoizingFunction<K,V>	memoize(Function<K,V> supplier)
static <T> MemoizingSupplier<T>	memoize(Supplier<T> supplier)
static Properties	merge(Properties a, Properties b)
static ExecutorService	newNamedWorkStealingPool(int parallelism, String prefix)
static ThreadFactory	newThreadFactory(String prefix)
static String	newThreadName(String prefix)
static <T, U> BiPredicate<T,U>	noOpBiPredicate()
static <T> Predicate<T>	noOpPredicate()
static void	run(ThrowingRunnable runnable)
static <T> Consumer<? super T>	tryAccept(Consumer<? super T> consumer)
static Runnable	tryCatch(Runnable runnable)
static void	tryRun(Runnable task)
static Throwable	unwrapException(Throwable e)

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectUtils

public ObjectUtils()

Method Details

noOpPredicate

public static <T> Predicate<T> noOpPredicate()

noOpBiPredicate

public static <T,
U> BiPredicate<T,U> noOpBiPredicate()

distinctByKey

public static <T> Predicate<T> distinctByKey(Function<? super T,?> keyExtractor)

iterate

public static <T> Stream<T> iterate(T seed,
 UnaryOperator<T> f,
 Predicate<T> breakCondition)

concat

@SafeVarargs
public static <T> Stream<T> concat(Stream<? extends T>... streams)

deduplicate

public static <T> List<T> deduplicate(List<T> list)

deduplicate

public static <T> List<T> deduplicate(List<T> list,
 Function<T,?> idFunction)

deduplicate

public static <T> List<T> deduplicate(List<T> list,
 Function<T,?> idFunction,
 boolean keepFirst)

asStream

public static Stream<?> asStream(Object value)

ifTrue

public static Consumer<Runnable> ifTrue(boolean check)

forceThrow

public static Object forceThrow(Throwable error)

call

public static <T> T call(Callable<T> callable)

run

public static void run(ThrowingRunnable runnable)

asCallable

public static Callable<?> asCallable(ThrowingRunnable runnable)

tryRun

public static void tryRun(Runnable task)

tryCatch

public static Runnable tryCatch(Runnable runnable)

asSupplier

public static <T> Supplier<T> asSupplier(Callable<T> callable)

asRunnable

public static Runnable asRunnable(ThrowingRunnable runnable)

asFunction

public static <T,
R> Function<T,R> asFunction(ThrowingFunction<T,R> function)

asConsumer

public static <T> Consumer<T> asConsumer(ThrowingConsumer<T> consumer)

asRunnable

public static Runnable asRunnable(Callable<?> callable)

getBytes

public static byte[] getBytes(ByteBuffer buffer)

unwrapException

public static Throwable unwrapException(Throwable e)

asProperties

public static Properties asProperties(String content)

copyOf

public static Properties copyOf(Properties properties)

merge

public static Properties merge(Properties a,
 Properties b)

memoize

public static <T> MemoizingSupplier<T> memoize(Supplier<T> supplier)

memoize

public static <K,
V> MemoizingFunction<K,V> memoize(Function<K,V> supplier)

memoize

public static <T,
U,
R> MemoizingBiFunction<T,U,R> memoize(BiFunction<T,U,R> supplier)

newThreadName

public static String newThreadName(String prefix)

newThreadFactory

public static ThreadFactory newThreadFactory(String prefix)

newNamedWorkStealingPool

public static ExecutorService newNamedWorkStealingPool(int parallelism,
 String prefix)

tryAccept

public static <T> Consumer<? super T> tryAccept(Consumer<? super T> consumer)