NStreamBase (Nuts Community Core Runtime 0.8.9.0 API)

java.lang.Object
- net.thevpc.nuts.runtime.standalone.util.stream.NStreamBase<T>

Type Parameters:

T - Type

All Implemented Interfaces:

AutoCloseable, Iterable<T>, NDescribable, NRedescribable<NStream<T>>, NStream<T>
```
public class NStreamBase<T>
extends Object
implements NStream<T>
```
Author:

thevpc

Field Summary

Fields
Modifier and Type Field and Description

protected NElement description

protected Supplier<NIterator<T>> iteratorSupplier

protected String name

protected Runnable onClose

Fields
Modifier and Type	Field and Description
`protected NElement`	`description`
`protected Supplier<NIterator<T>>`	`iteratorSupplier`
`protected String`	`name`
`protected Runnable`	`onClose`

Constructor Summary

Constructors
Constructor and Description

NStreamBase(String name, Supplier<NIterator<T>> iteratorSupplier, NElement description, Runnable onClose)

Constructors
Constructor and Description
`NStreamBase(String name, Supplier<NIterator<T>> iteratorSupplier, NElement description, Runnable onClose)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`allMatch(Predicate<? super T> predicate)`
`boolean`	`anyMatch(Predicate<? super T> predicate)`
`void`	`close()`
`NStream<T>`	`coalesce(Iterator<? extends T> other)`
`NStream<T>`	`coalesce(NStream<? extends T> other)`
`<R,A> R`	`collect(Collector<? super T,A,R> collector)`
`<R> R`	`collect(Supplier<R> supplier, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)`
`NStream<T>`	`concat(Iterator<? extends T> other)`
`NStream<T>`	`concat(NStream<? extends T> other)`
`long`	`count()`
`NElement`	`describe()`
`NStream<T>`	`distinct()`
`<R> NStream<T>`	`distinctBy(Function<T,R> condition)`
`NStream<T>`	`filter(Predicate<? super T> predicate)`
`NOptional<T>`	`findAny()`
`NOptional<T>`	`findFirst()`
`NOptional<T>`	`findLast()`
`NOptional<T>`	`findSingleton()`
`<R> NStream<R>`	`flatMap(Function<? super T,? extends Stream<? extends R>> mapper)`
`<R> NStream<R>`	`flatMapArray(Function<? super T,? extends R[]> mapper)`
`<R> NStream<R>`	`flatMapIter(Function<? super T,? extends Iterator<? extends R>> mapper)`
`<R> NStream<R>`	`flatMapList(Function<? super T,? extends List<? extends R>> mapper)`
`<R> NStream<R>`	`flatMapStream(Function<? super T,? extends NStream<? extends R>> mapper)`
`DoubleStream`	`flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)`
`IntStream`	`flatMapToInt(Function<? super T,? extends IntStream> mapper)`
`LongStream`	`flatMapToLong(Function<? super T,? extends LongStream> mapper)`
`<K> Map<K,List<T>>`	`groupBy(Function<? super T,? extends K> classifier)`
`<K> NStream<Map.Entry<K,List<T>>>`	`groupedBy(Function<? super T,? extends K> classifier)`
`<V> NStream<V>`	`instanceOf(Class<V> type)`
`NIterator<T>`	`iterator()`
`NStream<T>`	`limit(long maxSize)`
`<R> NStream<R>`	`map(Function<? super T,? extends R> mapper)`
`DoubleStream`	`mapToDouble(ToDoubleFunction<? super T> mapper)`
`IntStream`	`mapToInt(ToIntFunction<? super T> mapper)`
`LongStream`	`mapToLong(ToLongFunction<? super T> mapper)`
`<R> NStream<R>`	`mapUnsafe(UnsafeFunction<? super T,? extends R> mapper)`
`<R> NStream<R>`	`mapUnsafe(UnsafeFunction<? super T,? extends R> mapper, Function<Exception,? extends R> onError)`
`NOptional<T>`	`max(Comparator<? super T> comparator)`
`NOptional<T>`	`min(Comparator<? super T> comparator)`
`NStream<T>`	`nonBlank()`
`boolean`	`noneMatch(Predicate<? super T> predicate)`
`NStream<T>`	`nonNull()`
`static <X> NStream<X>`	`ofCollection(String name, Collection<X> o)`
`static <X> NStream<X>`	`ofCollection(String name, Collection<X> o, Runnable onClose)`
`static <X> NStream<X>`	`ofEmpty(String name)`
`static <X> NStream<X>`	`ofEmpty(String name, Runnable onClose)`
`static <X> NStream<X>`	`ofIterable(String name, NIterable<X> o)`
`static <X> NStream<X>`	`ofIterable(String name, NIterable<X> o, Runnable onClose)`
`static <X> NStream<X>`	`ofIterator(String name, NIterator<X> o)`
`static <X> NStream<X>`	`ofIterator(String name, NIterator<X> o, Runnable onClose)`
`static <X> NStream<X>`	`ofJavaStream(String name, Stream<X> o)`
`static <X> NStream<X>`	`ofJavaStream(String name, Stream<X> o, Runnable onClose)`
`NStream<T>`	`onClose(Runnable closeHandler)`
`NStream<T>`	`skip(long n)`
`NStream<T>`	`sorted()`
`NStream<T>`	`sorted(NComparator<T> comp)`
`Stream<T>`	`stream()`
`<A> A[]`	`toArray(IntFunction<A[]> generator)`
`boolean[]`	`toBooleanArray()`
`byte[]`	`toByteArray()`
`char[]`	`toCharArray()`
`double[]`	`toDoubleArray()`
`float[]`	`toFloatArray()`
`int[]`	`toIntArray()`
`List<T>`	`toList()`
`long[]`	`toLongArray()`
`<K,U> Map<K,U>`	`toMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper)`
`<K,U> Map<K,U>`	`toOrderedMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper)`
`Set<T>`	`toOrderedSet()`
`Set<T>`	`toSet()`
`short[]`	`toShortArray()`
`<K,U> Map<K,U>`	`toSortedMap(Function<? super T,? extends K> keyMapper, Function<? super T,? extends U> valueMapper)`
`Set<T>`	`toSortedSet()`
`NStream<T>`	`withDescription(Supplier<NElement> description)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.thevpc.nuts.util.NStream
ofArray, ofArray, ofArray, ofArray, ofArray, ofArray, ofArray, ofArray, ofEmpty, ofIterable, ofIterator, ofOptional, ofOptional, ofSingleton, ofStream

Methods inherited from interface java.lang.Iterable
forEach, spliterator

Field Detail

name
```
protected String name
```

iteratorSupplier

protected Supplier<NIterator<T>> iteratorSupplier

description
```
protected NElement description
```

onClose
```
protected Runnable onClose
```

Constructor Detail

NStreamBase

public NStreamBase(String name,
                   Supplier<NIterator<T>> iteratorSupplier,
                   NElement description,
                   Runnable onClose)

Method Detail

ofEmpty

public static <X> NStream<X> ofEmpty(String name)

ofJavaStream

public static <X> NStream<X> ofJavaStream(String name,
                                          Stream<X> o)

ofIterable

public static <X> NStream<X> ofIterable(String name,
                                        NIterable<X> o)

ofIterator

public static <X> NStream<X> ofIterator(String name,
                                        NIterator<X> o)

ofCollection

public static <X> NStream<X> ofCollection(String name,
                                          Collection<X> o)

ofEmpty

public static <X> NStream<X> ofEmpty(String name,
                                     Runnable onClose)

ofJavaStream

public static <X> NStream<X> ofJavaStream(String name,
                                          Stream<X> o,
                                          Runnable onClose)

ofIterable

public static <X> NStream<X> ofIterable(String name,
                                        NIterable<X> o,
                                        Runnable onClose)

ofIterator

public static <X> NStream<X> ofIterator(String name,
                                        NIterator<X> o,
                                        Runnable onClose)

ofCollection

public static <X> NStream<X> ofCollection(String name,
                                          Collection<X> o,
                                          Runnable onClose)

toList
```
public List<T> toList()
```
Specified by:

toList in interface NStream<T>

toSet
```
public Set<T> toSet()
```
Specified by:

toSet in interface NStream<T>

toSortedSet
```
public Set<T> toSortedSet()
```
Specified by:

toSortedSet in interface NStream<T>

toOrderedSet
```
public Set<T> toOrderedSet()
```
Specified by:

toOrderedSet in interface NStream<T>

findLast
```
public NOptional<T> findLast()
```
Specified by:

findLast in interface NStream<T>

findSingleton
```
public NOptional<T> findSingleton()
```
Specified by:

findSingleton in interface NStream<T>

stream
```
public Stream<T> stream()
```
Specified by:

stream in interface NStream<T>

count
```
public long count()
```
Specified by:

count in interface NStream<T>

map

public <R> NStream<R> map(Function<? super T,? extends R> mapper)

Specified by:: map in interface NStream<T>

mapUnsafe

public <R> NStream<R> mapUnsafe(UnsafeFunction<? super T,? extends R> mapper,
                                Function<Exception,? extends R> onError)

Specified by:: mapUnsafe in interface NStream<T>

mapUnsafe

public <R> NStream<R> mapUnsafe(UnsafeFunction<? super T,? extends R> mapper)

Specified by:: mapUnsafe in interface NStream<T>

sorted
```
public NStream<T> sorted()
```
Specified by:

sorted in interface NStream<T>

sorted

public NStream<T> sorted(NComparator<T> comp)

Specified by:: sorted in interface NStream<T>

distinct
```
public NStream<T> distinct()
```
Specified by:

distinct in interface NStream<T>

distinctBy

public <R> NStream<T> distinctBy(Function<T,R> condition)

Specified by:: distinctBy in interface NStream<T>

nonNull
```
public NStream<T> nonNull()
```
Specified by:

nonNull in interface NStream<T>

nonBlank
```
public NStream<T> nonBlank()
```
Specified by:

nonBlank in interface NStream<T>

filter

public NStream<T> filter(Predicate<? super T> predicate)

Specified by:: filter in interface NStream<T>

coalesce

public NStream<T> coalesce(Iterator<? extends T> other)

Specified by:: coalesce in interface NStream<T>

iterator
```
public NIterator<T> iterator()
```
Specified by:

iterator in interface Iterable<T>

Specified by:

iterator in interface NStream<T>

concat

public NStream<T> concat(Iterator<? extends T> other)

Specified by:: concat in interface NStream<T>

coalesce

public NStream<T> coalesce(NStream<? extends T> other)

Specified by:: coalesce in interface NStream<T>

concat

public NStream<T> concat(NStream<? extends T> other)

Specified by:: concat in interface NStream<T>

toBooleanArray
```
public boolean[] toBooleanArray()
```
Specified by:

toBooleanArray in interface NStream<T>

toByteArray
```
public byte[] toByteArray()
```
Specified by:

toByteArray in interface NStream<T>

toCharArray
```
public char[] toCharArray()
```
Specified by:

toCharArray in interface NStream<T>

toShortArray
```
public short[] toShortArray()
```
Specified by:

toShortArray in interface NStream<T>

toFloatArray
```
public float[] toFloatArray()
```
Specified by:

toFloatArray in interface NStream<T>

toIntArray
```
public int[] toIntArray()
```
Specified by:

toIntArray in interface NStream<T>

toLongArray
```
public long[] toLongArray()
```
Specified by:

toLongArray in interface NStream<T>

toDoubleArray
```
public double[] toDoubleArray()
```
Specified by:

toDoubleArray in interface NStream<T>

mapToInt

public IntStream mapToInt(ToIntFunction<? super T> mapper)

Specified by:: mapToInt in interface NStream<T>

mapToLong

public LongStream mapToLong(ToLongFunction<? super T> mapper)

Specified by:: mapToLong in interface NStream<T>

mapToDouble

public DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)

Specified by:: mapToDouble in interface NStream<T>

toArray

public <A> A[] toArray(IntFunction<A[]> generator)

Specified by:: toArray in interface NStream<T>

toMap

public <K,U> Map<K,U> toMap(Function<? super T,? extends K> keyMapper,
                            Function<? super T,? extends U> valueMapper)

Specified by:: toMap in interface NStream<T>

toOrderedMap

public <K,U> Map<K,U> toOrderedMap(Function<? super T,? extends K> keyMapper,
                                   Function<? super T,? extends U> valueMapper)

Specified by:: toOrderedMap in interface NStream<T>

toSortedMap

public <K,U> Map<K,U> toSortedMap(Function<? super T,? extends K> keyMapper,
                                  Function<? super T,? extends U> valueMapper)

Specified by:: toSortedMap in interface NStream<T>

flatMapIter

public <R> NStream<R> flatMapIter(Function<? super T,? extends Iterator<? extends R>> mapper)

Specified by:: flatMapIter in interface NStream<T>

flatMapList

public <R> NStream<R> flatMapList(Function<? super T,? extends List<? extends R>> mapper)

Specified by:: flatMapList in interface NStream<T>

flatMapArray

public <R> NStream<R> flatMapArray(Function<? super T,? extends R[]> mapper)

Specified by:: flatMapArray in interface NStream<T>

flatMap

public <R> NStream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)

Specified by:: flatMap in interface NStream<T>

flatMapStream

public <R> NStream<R> flatMapStream(Function<? super T,? extends NStream<? extends R>> mapper)

Specified by:: flatMapStream in interface NStream<T>

groupBy

public <K> Map<K,List<T>> groupBy(Function<? super T,? extends K> classifier)

Specified by:: groupBy in interface NStream<T>

groupedBy

public <K> NStream<Map.Entry<K,List<T>>> groupedBy(Function<? super T,? extends K> classifier)

Specified by:: groupedBy in interface NStream<T>

findAny
```
public NOptional<T> findAny()
```
Specified by:

findAny in interface NStream<T>

findFirst
```
public NOptional<T> findFirst()
```
Specified by:

findFirst in interface NStream<T>

flatMapToDouble

public DoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)

Specified by:: flatMapToDouble in interface NStream<T>

flatMapToInt

public IntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)

Specified by:: flatMapToInt in interface NStream<T>

flatMapToLong

public LongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)

Specified by:: flatMapToLong in interface NStream<T>

allMatch

public boolean allMatch(Predicate<? super T> predicate)

Specified by:: allMatch in interface NStream<T>

anyMatch

public boolean anyMatch(Predicate<? super T> predicate)

Specified by:: anyMatch in interface NStream<T>

noneMatch

public boolean noneMatch(Predicate<? super T> predicate)

Specified by:: noneMatch in interface NStream<T>

limit
```
public NStream<T> limit(long maxSize)
```
Specified by:

limit in interface NStream<T>

collect

public <R> R collect(Supplier<R> supplier,
                     BiConsumer<R,? super T> accumulator,
                     BiConsumer<R,R> combiner)

Specified by:: collect in interface NStream<T>

collect

public <R,A> R collect(Collector<? super T,A,R> collector)

Specified by:: collect in interface NStream<T>

min

public NOptional<T> min(Comparator<? super T> comparator)

Specified by:: min in interface NStream<T>

max

public NOptional<T> max(Comparator<? super T> comparator)

Specified by:: max in interface NStream<T>

describe
```
public NElement describe()
```
Specified by:

describe in interface NDescribable

withDescription
```
public NStream<T> withDescription(Supplier<NElement> description)
```
Specified by:

withDescription in interface NRedescribable<NStream<T>>

skip
```
public NStream<T> skip(long n)
```
Specified by:

skip in interface NStream<T>

instanceOf
```
public <V> NStream<V> instanceOf(Class<V> type)
```
Specified by:

instanceOf in interface NStream<T>

onClose

public NStream<T> onClose(Runnable closeHandler)

Specified by:: onClose in interface NStream<T>

close
```
public void close()
```
Specified by:

close in interface AutoCloseable

Specified by:

close in interface NStream<T>

Class NStreamBase<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface net.thevpc.nuts.util.NStream

Methods inherited from interface java.lang.Iterable

Field Detail

name

iteratorSupplier

description

onClose

Constructor Detail

NStreamBase

Method Detail

ofEmpty

ofJavaStream

ofIterable

ofIterator

ofCollection

ofEmpty

ofJavaStream

ofIterable

ofIterator

ofCollection

toList

toSet

toSortedSet

toOrderedSet

findLast

findSingleton

stream

count

map

mapUnsafe

mapUnsafe

sorted

sorted

distinct

distinctBy

nonNull

nonBlank

filter

coalesce

iterator

concat

coalesce

concat

toBooleanArray

toByteArray

toCharArray

toShortArray

toFloatArray

toIntArray

toLongArray

toDoubleArray

mapToInt

mapToLong

mapToDouble

toArray

toMap

toOrderedMap

toSortedMap

flatMapIter

flatMapList

flatMapArray

flatMap

flatMapStream

groupBy

groupedBy

findAny

findFirst

flatMapToDouble

flatMapToInt

flatMapToLong

allMatch

anyMatch

noneMatch

limit

collect