T
- public interface Linkable<T>
linked
to a
Consumer to complete the pipeline or no values will be processed.
Only stateless operations are currently supported. Operations that require
access to previous values (limit, sort, distinct, etc.) require combining
with one of the other mechanisms (eg. Inject
or Ref
) for
retaining state across code changes.
Modifier and Type | Interface and Description |
---|---|
static interface |
Linkable.Double
A double primitive specialisation of Linkable.
|
static interface |
Linkable.Int
An int primitive specialisation of Linkable.
|
Modifier and Type | Method and Description |
---|---|
default Linkable<T> |
filter(Predicate<? super T> predicate)
Returns a Linkable that wraps this Linkable and filters values using the
provided predicate function.
|
void |
link(Consumer<T> consumer)
Link to a Consumer to process values.
|
default <R> Linkable<R> |
map(Function<? super T,? extends R> function)
Returns a Linkable that wraps this Linkable and transforms values using
the provided mapping function.
|
void link(Consumer<T> consumer)
consumer
- function to process received values.default <R> Linkable<R> map(Function<? super T,? extends R> function)
R
- function
- transform values