Package uk.gov.gchq.gaffer.commonutil.stream

Class FlatMapStreamSupplier<T,U>

java.lang.Object

uk.gov.gchq.gaffer.commonutil.stream.FlatMapStreamSupplier<T,U>

Type Parameters:

T - the type of input objects

U - the type of output objects

All Implemented Interfaces:

Closeable, AutoCloseable, Supplier<Stream<U>>, StreamSupplier<U>

public class FlatMapStreamSupplier<T,U>
extends Object
implements StreamSupplier<U>

A StreamSupplier which uses a Function to convert the input objects into output objects.

Constructor Summary

Constructors

Constructor	Description
FlatMapStreamSupplier(Iterable<T> input, Function<? super T,? extends Stream<U>> function)	Default constructor.

Method Summary

Modifier and Type	Method	Description
void	close()
Stream<U>	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatMapStreamSupplier

public FlatMapStreamSupplier(Iterable<T> input,
                             Function<? super T,? extends Stream<U>> function)

Default constructor.

Parameters:

input - the input iterable

function - the mapping function

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

get

public Stream<U> get()

Specified by:

get in interface Supplier<T>