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

Class ApplyToStreamInputChain<I,O>

java.lang.Object

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

Type Parameters:

I - the type of each item in the input stream

O - the type of each item in the output stream

All Implemented Interfaces:

Chain<Stream<I>,Stream<O>>

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

this chain applies another chain (which is passed as a constructor parameter) to each item of the input stream.

Constructor Summary

Constructors

Constructor	Description
ApplyToStreamInputChain(Chain<I,O> applyToStreamItemChain)

Method Summary

Modifier and Type	Method	Description
Stream<O>	run(Stream<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

ApplyToStreamInputChain

public ApplyToStreamInputChain(Chain<I,O> applyToStreamItemChain)

Parameters:

applyToStreamItemChain - applyToStreamItemChain

Method Details

run

public Stream<O> run(Stream<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