| Package | Description |
|---|---|
| io.jstuff.pipeline |
Pipeline conversion library for Java
|
| io.jstuff.pipeline.buffer |
Buffering classes for pipelines
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ObjectIntPipeline<A,R>
A pipeline that takes object values and emits integer values.
|
interface |
Pipeline<A,E,R>
A pipeline that accepts and emits values of the specified types.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAcceptor<A,R>
Abstract implementation of
Acceptor. |
class |
AbstractObjectIntPipeline<A,R>
Abstract base class for
IntObjectPipeline implementations. |
class |
AbstractPipeline<A,E,R>
Abstract implementation of
Pipeline. |
class |
Counter<A> |
class |
Filter<A,R>
A pipeline that filters objects based on a specified predicate.
|
class |
Fold<A> |
class |
ForkPipeline<A,R> |
class |
ListAcceptor<A>
|
class |
Mapper<A,E,R> |
class |
SetAcceptor<A>
|
| Modifier and Type | Method and Description |
|---|---|
Acceptor<? super E,? extends R> |
AbstractIntObjectPipeline.getDownstream()
Get the downstream
Acceptor |
Acceptor<? super E,? extends R> |
AbstractPipeline.getDownstream()
Get the downstream
Acceptor |
| Modifier and Type | Method and Description |
|---|---|
static <A,R> R |
Pipelines.process(Iterable<A> iterable,
Acceptor<A,R> downstream) |
| Constructor and Description |
|---|
AbstractIntObjectPipeline(Acceptor<? super E,? extends R> downstream)
Construct an
AbstractIntObjectPipeline with the given downstream Acceptor. |
AbstractPipeline(Acceptor<? super E,? extends R> downstream)
Construct an
AbstractPipeline with the given downstream Acceptor. |
Filter(Acceptor<? super A,? extends R> downstream,
Predicate<A> predicate)
|
ForkPipeline(Acceptor<? super A,? extends R> downstream1,
Acceptor<? super A,? extends R> downstream2)
Construct a
Fork with the given downstream Acceptor. |
ForkPipeline(Acceptor<? super A,? extends R> downstream1,
Acceptor<? super A,? extends R> downstream2)
Construct a
Fork with the given downstream Acceptor. |
LinePipeline(Acceptor<? super String,? extends R> downstream)
Construct a
LinePipeline with the given downstream Acceptor. |
LinePipeline(Acceptor<? super String,? extends R> downstream,
int maxLength)
Construct a
LinePipeline with the given downstream Acceptor amd the specified maximum line length. |
Mapper(Acceptor<? super E,? extends R> downstream,
Function<? super A,? extends E> function) |
| Modifier and Type | Class and Description |
|---|---|
class |
ByteArrayPipeline<R>
A pipeline that takes
byte arrays and emits each byte as an int. |
class |
ByteBufferPipeline<R>
|
class |
CharBufferPipeline<R>
A pipeline that takes
CharBuffers and emits each character as an int. |
class |
CharSequencePipeline<R>
A pipeline that takes
CharSequence objects (e.g. |
Copyright © 2025. All rights reserved.