public final class Streams extends Object
Utility for streams
Modifier and Type | Class and Description |
---|---|
static interface |
Streams.CheckedBiConsumer<U,T> |
static interface |
Streams.CheckedConsumer<T> |
static interface |
Streams.CheckedFunction<In,Out> |
static interface |
Streams.CheckedPredicate<T> |
static interface |
Streams.CheckedSupplier<Out> |
static class |
Streams.UncheckedException
Exception indicating that Checked* threw an exception and the default handler was used
|
Modifier and Type | Field and Description |
---|---|
static boolean |
NOT_PARALLEL |
static boolean |
PARALLEL |
static long |
UNKNOWN_SIZE |
Constructor and Description |
---|
Streams() |
Modifier and Type | Method and Description |
---|---|
static <Input,Output> |
applyTerminalAndClose(Stream<Input> theStream,
Function<Stream<Input>,Output> theFinisher)
Apply the given terminal operation to the stream returning the result and close the stream.
|
static <T> Stream<T> |
concat(Stream<T> theStream,
Stream<T> theOtherStream,
Stream<T>... theMoreStreams) |
static <T> Predicate<? super T> |
distinctByKey(Function<? super T,Object> theKey)
A simple stateful predicate for filtering out stream elements which agree on their key values.
|
static <T> CloseableIterator<T> |
flatIterator(Stream<Stream<T>> theStream) |
static <T> Stream<T> |
flatten(Stream<Stream<T>> theStream) |
static <T,E extends Throwable> |
forEachChecked(Stream<T> theStream,
Streams.CheckedConsumer<T> theConsumer) |
static <T> Function<Optional<T>,Stream<T>> |
optional()
|
static <T> Stream<T> |
stream(Iterable<T> theIterable)
|
static <T> Stream<T> |
stream(Iterator<? extends T> theIter) |
static <T> Stream<T> |
stream(Iterator<? extends T> theIter,
long theSize) |
static <In,Out> Function<In,Out> |
unchecked(Streams.CheckedFunction<In,Out> theFunction) |
static <In,Out> Function<In,Out> |
unchecked(Streams.CheckedFunction<In,Out> theFunction,
Consumer<Throwable> theHandler) |
static <U,T> BiConsumer<U,T> |
uncheckedConsumer(Streams.CheckedBiConsumer<U,T> theConsumer) |
static <U,T> BiConsumer<U,T> |
uncheckedConsumer(Streams.CheckedBiConsumer<U,T> theConsumer,
Consumer<Throwable> theHandler) |
static <T> Consumer<T> |
uncheckedConsumer(Streams.CheckedConsumer<T> theConsumer) |
static <T> Consumer<T> |
uncheckedConsumer(Streams.CheckedConsumer<T> theConsumer,
Consumer<Throwable> theHandler) |
static <In> Predicate<In> |
uncheckedPredicate(Streams.CheckedPredicate<In> thePredicate) |
static <In> Predicate<In> |
uncheckedPredicate(Streams.CheckedPredicate<In> thePredicate,
Consumer<Throwable> theHandler) |
public static final boolean NOT_PARALLEL
public static final boolean PARALLEL
public static final long UNKNOWN_SIZE
public static <T> Function<Optional<T>,Stream<T>> optional()
Stream
of optionals
into a Stream
of
the references they hold. To be used with Stream.flatMap(Function)
.T
- the optional's typepublic static <T> Stream<T> stream(Iterable<T> theIterable)
theIterable
- the iterable@SafeVarargs public static <T> Stream<T> concat(Stream<T> theStream, Stream<T> theOtherStream, Stream<T>... theMoreStreams)
public static <Input,Output> Output applyTerminalAndClose(Stream<Input> theStream, Function<Stream<Input>,Output> theFinisher)
theStream
- the streamtheFinisher
- the function which will apply the terminal operation and return the resultpublic static <T,E extends Throwable> void forEachChecked(Stream<T> theStream, Streams.CheckedConsumer<T> theConsumer) throws E extends Throwable
E extends Throwable
public static <In,Out> Function<In,Out> unchecked(Streams.CheckedFunction<In,Out> theFunction)
public static <In,Out> Function<In,Out> unchecked(Streams.CheckedFunction<In,Out> theFunction, Consumer<Throwable> theHandler)
public static <In> Predicate<In> uncheckedPredicate(Streams.CheckedPredicate<In> thePredicate)
public static <In> Predicate<In> uncheckedPredicate(Streams.CheckedPredicate<In> thePredicate, Consumer<Throwable> theHandler)
public static <T> Consumer<T> uncheckedConsumer(Streams.CheckedConsumer<T> theConsumer)
public static <U,T> BiConsumer<U,T> uncheckedConsumer(Streams.CheckedBiConsumer<U,T> theConsumer)
public static <U,T> BiConsumer<U,T> uncheckedConsumer(Streams.CheckedBiConsumer<U,T> theConsumer, Consumer<Throwable> theHandler)
public static <T> Consumer<T> uncheckedConsumer(Streams.CheckedConsumer<T> theConsumer, Consumer<Throwable> theHandler)
public static <T> CloseableIterator<T> flatIterator(Stream<Stream<T>> theStream)
Copyright © 2010-2016 Stardog Union. All Rights Reserved.