public class Data extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Data.In<T>
Input port pipe.
|
static class |
Data.Out<T>
Input port pipe.
|
static interface |
Data.Packet<T>
A data holder used to wrap data of type T to be passed around a Pipe
graph.
|
static class |
Data.Pipe<T>
The base type of pipes that can be connected to form processing graphs.
|
static class |
Data.Sink<T>
Data sink to drive pipe graph.
|
Modifier and Type | Method and Description |
---|---|
static <T> Data.Pipe<T> |
apply(Function<? super T,? extends T> function)
Create a pipe that applies the function to every type T passing through.
|
static <T> Data.Pipe<T> |
link(Data.Pipe<T>... pipes)
Link provided Data.Pipes together.
|
static <T> Data.Pipe<T> |
supply(Supplier<? extends T> supplier)
Create a pipe that supplies new instances of type T.
|
static <T> Data.Pipe<T> |
with(Consumer<? super T> consumer)
Create a pipe that applies the consumer to every type T passing through.
|
@SafeVarargs public static final <T> Data.Pipe<T> link(Data.Pipe<T>... pipes)
T
- common type of data supported by pipespipes
- pipes to connectpublic static final <T> Data.Pipe<T> with(Consumer<? super T> consumer)
T
- type of dataconsumer
- consumer function to apply to data of type Tpublic static final <T> Data.Pipe<T> supply(Supplier<? extends T> supplier)
T
- type of data to supplysupplier
- function to supply instance of Tpublic static final <T> Data.Pipe<T> apply(Function<? super T,? extends T> function)
T
- type of datafunction
- function to apply to data