reactor.function

Class Suppliers

java.lang.Object

reactor.function.Suppliers

public abstract class Suppliers
extends java.lang.Object

Helper class for working tying Suppliers to Iterables and other types of collections.

Method Summary

Modifier and Type	Method and Description
static <T> Supplier<T>	collect(java.util.List<Supplier<T>> suppliers) Create a Supplier that aggregates the given list of suppliers by calling each one, in turn, until the supplier returns null.
static <T> Supplier<T>	drain(java.lang.Iterable<T> c) Create a Supplier which drains the contents of the given Iterable by internally creating an Iterator and delegating each call of Supplier.get() to Iterator.next().
static <T> Supplier<T>	drainAll(java.lang.Iterable<java.lang.Iterable<T>> iters) Create a Supplier which drains all of the given Iterables.
static <T> Supplier<T>	filter(java.lang.Iterable<T> src, Predicate<T> predicate) Filter the given Iterable using the given Predicate so that calls to the return Supplier.get() will provide only items from the original collection which pass the predicate test.
static <T> Supplier<T>	roundRobin(T... objs) Create a Supplier that continually round-robin load balances each call to Supplier.get() by iterating over the objects.
static <T> Supplier<T>	supply(T obj) Wrap the given object that will supply the given object every time Supplier.get() is called.
static <T> Supplier<T>	supplyOnce(T obj) Supply the given object only once, the first time Supplier.get() is invoked.
static <T> Supplier<T>	supplyWhile(T obj, Predicate<T> predicate) Supply the given object to callers only as long as the given Predicate returns true.

Methods inherited from class java.lang.Object

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

Method Detail

supply

public static <T> Supplier<T> supply(T obj)

Wrap the given object that will supply the given object every time Supplier.get() is called.

Type Parameters:

T - type of the supplied object

Parameters:

obj - the object to supply

Returns:

the new Supplier

supplyOnce

public static <T> Supplier<T> supplyOnce(T obj)

Supply the given object only once, the first time Supplier.get() is invoked.

Type Parameters:

T - type of the supplied object

Parameters:

obj - the object to supply

Returns:

the new Supplier

supplyWhile

public static <T> Supplier<T> supplyWhile(T obj,
                                          Predicate<T> predicate)

Supply the given object to callers only as long as the given Predicate returns true.

Type Parameters:

T - type of the supplied object

Parameters:

obj - the object to supply

predicate - the predicate to check to determine whether or not to supply the given value

Returns:

the new Supplier

roundRobin

public static <T> Supplier<T> roundRobin(T... objs)

Create a Supplier that continually round-robin load balances each call to Supplier.get() by iterating over the objects. When the end is reached, it wraps around to the first object and keeps providing objects to callers.

Type Parameters:

T - type of the supplied object

Parameters:

objs - the objects to load-balance

Returns:

the new Supplier

filter

public static <T> Supplier<T> filter(java.lang.Iterable<T> src,
                                     Predicate<T> predicate)

Filter the given Iterable using the given Predicate so that calls to the return Supplier.get() will provide only items from the original collection which pass the predicate test.

Type Parameters:

T - type of the source

Parameters:

src - the source of objects to filter

predicate - the Predicate to test items against

Returns:

the new Supplier

drain

public static <T> Supplier<T> drain(java.lang.Iterable<T> c)

Create a Supplier which drains the contents of the given Iterable by internally creating an Iterator and delegating each call of Supplier.get() to Iterator.next().

Type Parameters:

T - type of the source

Parameters:

c - the collection to drain

Returns:

the new Supplier

drainAll

public static <T> Supplier<T> drainAll(java.lang.Iterable<java.lang.Iterable<T>> iters)

Create a Supplier which drains all of the given Iterables.

Type Parameters:

T - type of the source

Parameters:

iters - the collections to drain

Returns:

the new Supplier

See Also:

drain(Iterable)

collect

public static <T> Supplier<T> collect(java.util.List<Supplier<T>> suppliers)

Create a Supplier that aggregates the given list of suppliers by calling each one, in turn, until the supplier returns null. The aggregator then goes on to the next supplier in the list and delegates calls to that supplier, and so on, until the end of the list is reached.

Type Parameters:

T - type of the source

Parameters:

suppliers - the list of suppliers to delegate to

Returns:

the new Supplier