org.infinispan.stream.impl.intops.object

Class FlatMapOperation<I,O>

java.lang.Object

org.infinispan.stream.impl.intops.object.FlatMapOperation<I,O>

Type Parameters:

I - the type of the input stream

O - the type of the output stream

All Implemented Interfaces:

IntermediateOperation<I,Stream<I>,O,Stream<O>>

public class FlatMapOperation<I,O>
extends Object
implements IntermediateOperation<I,Stream<I>,O,Stream<O>>

Performs flat map operation on a regular Stream

Constructor Summary

Constructors

Constructor and Description
FlatMapOperation(Function<? super I,? extends Stream<? extends O>> function)

Method Summary

Modifier and Type	Method and Description
Function<? super I,? extends Stream<? extends O>>	getFunction()
Stream<O>	perform(Stream<I> stream) Performs the actualy intermediate operation returning the resulting stream

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.stream.impl.intops.IntermediateOperation

handleInjection

Constructor Detail

FlatMapOperation

public FlatMapOperation(Function<? super I,? extends Stream<? extends O>> function)

Method Detail

perform

public Stream<O> perform(Stream<I> stream)

Description copied from interface: IntermediateOperation

Performs the actualy intermediate operation returning the resulting stream

Specified by:

perform in interface IntermediateOperation<I,Stream<I>,O,Stream<O>>

Parameters:

stream - the stream to have the operation performed on

Returns:

the resulting stream after the operation was applied

getFunction

public Function<? super I,? extends Stream<? extends O>> getFunction()