Package com.github.hakenadu.javalangchains.chains.base

Class JoinChain<I,O>

java.lang.Object

com.github.hakenadu.javalangchains.chains.base.JoinChain<I,O>

Type Parameters:

I - Input type of joined chains

O - Output type of joined chains

All Implemented Interfaces:

Chain<I,Stream<O>>

public final class JoinChain<I,O>
extends Object
implements Chain<I,Stream<O>>

This Chain is used to join multiple other chains. Their output is provided as a Stream which will be passed as an input to subsequent chains.

Constructor Summary

Constructors

Constructor	Description
JoinChain(boolean parallel, Chain<I,O>... chains)
JoinChain(boolean parallel, List<Chain<I,O>> chains)
JoinChain(Chain<I,O>... chains)
JoinChain(List<Chain<I,O>> chains)

Method Summary

Modifier and Type	Method	Description
Stream<O>	run(I input)	Execute this Chain

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.hakenadu.javalangchains.chains.Chain

chain

Constructor Details

JoinChain

public JoinChain(boolean parallel, List<Chain<I,O>> chains)

Parameters:

parallel - parallel

chains - chains

JoinChain

public JoinChain(List<Chain<I,O>> chains)

Parameters:

chains - chains

JoinChain

@SafeVarargs public JoinChain(boolean parallel, Chain<I,O>... chains)

Parameters:

parallel - parallel

chains - chains

JoinChain

@SafeVarargs public JoinChain(Chain<I,O>... chains)

Parameters:

chains - chains

Method Details

run

public Stream<O> run(I input)

Description copied from interface: Chain

Execute this Chain

Specified by:

run in interface Chain<I,O>

Parameters:

input - this chain's input

Returns:

this chain's output