reactor.function

Class Functions

java.lang.Object

reactor.function.Functions

Direct Known Subclasses:

Fn

public abstract class Functions
extends java.lang.Object

Helper methods to provide syntax sugar for working with functional components in Reactor.

Constructor Summary

Constructors

Constructor and Description
Functions()

Method Summary

Modifier and Type	Method and Description
static <T> Consumer<T>	chain(Consumer<T>... consumers) Chain a set of Consumers together into a single Consumer.
static <T> Consumer<T>	consumer(java.lang.Runnable r) Wrap the given Runnable and compose a new Consumer.
static <T,V> Function<T,V>	function(java.util.concurrent.Callable<V> c) Wrap the given Callable and compose a new Function.
static <T> Supplier<T>	supplier(java.util.concurrent.Callable<T> callable) Creates a Supplier that will call the callable each time it's asked for a value.
static <T> Supplier<T>	supplier(java.lang.Class<T> type) Creates a Supplier that will return a new instance of type each time it's called.
static <T> Supplier<T>	supplier(java.util.concurrent.Future<T> future) Creates a Supplier that will get its value from the future each time it's asked for a value.
static <T> Supplier<T>	supplier(T value) Creates a Supplier that will always return the given value.

Methods inherited from class java.lang.Object

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

Constructor Detail

Functions

public Functions()

Method Detail

chain

@SafeVarargs
public static <T> Consumer<T> chain(Consumer<T>... consumers)

Chain a set of Consumers together into a single Consumer.

Type Parameters:

T - type of the event handled by the Consumer

Parameters:

consumers - the Consumers to chain together

Returns:

a new Consumer

function

public static <T,V> Function<T,V> function(java.util.concurrent.Callable<V> c)

Wrap the given Callable and compose a new Function.

Parameters:

c - The Callable.

Returns:

An Consumer that executes the Callable.

consumer

public static <T> Consumer<T> consumer(java.lang.Runnable r)

Wrap the given Runnable and compose a new Consumer.

Parameters:

r - The Runnable.

Returns:

An Consumer that executes the Runnable.

supplier

public static <T> Supplier<T> supplier(T value)

Creates a Supplier that will always return the given value.

Parameters:

value - the value to be supplied

Returns:

the supplier for the value

supplier

public static <T> Supplier<T> supplier(java.lang.Class<T> type)

Creates a Supplier that will return a new instance of type each time it's called.

Parameters:

type - The type to create

Returns:

The supplier that will create instances

Throws:

java.lang.IllegalArgumentException - if type does not have a zero-args constructor

supplier

public static <T> Supplier<T> supplier(java.util.concurrent.Callable<T> callable)

Creates a Supplier that will call the callable each time it's asked for a value.

Parameters:

callable - The Callable.

Returns:

A Supplier that executes the Callable.

supplier

public static <T> Supplier<T> supplier(java.util.concurrent.Future<T> future)

Creates a Supplier that will get its value from the future each time it's asked for a value.

Parameters:

future - The future to get values from

Returns:

A Supplier that gets its values from the Future