AbstractObjectStream (LensKit 3.0-SNAPSHOT)

java.lang.Object
- org.lenskit.util.io.AbstractObjectStream<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<T>, java.util.stream.BaseStream<T,java.util.stream.Stream<T>>, java.util.stream.Stream<T>, ObjectStream<T>

Direct Known Subclasses:

GroupingObjectStream, LineStream
```
public abstract class AbstractObjectStream<T>
extends java.lang.Object
implements ObjectStream<T>
```
Base class to make ObjectStreams easier to implement.

Compatibility

Public

Nested Class Summary
- Nested classes/interfaces inherited from interface java.util.stream.Stream
  java.util.stream.Stream.Builder<T>

Field Summary

Fields
Modifier and Type Field and Description

protected java.util.stream.Stream<T> stream

Fields
Modifier and Type	Field and Description
`protected java.util.stream.Stream<T>`	`stream`

Constructor Summary

Constructors
Constructor and Description

AbstractObjectStream()

Constructors
Constructor and Description
`AbstractObjectStream()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`allMatch(java.util.function.Predicate<? super T> predicate)`
`boolean`	`anyMatch(java.util.function.Predicate<? super T> predicate)`
`void`	`close()` No-op implementation of the `ObjectStream.close()` method.
`<R,A> R`	`collect(java.util.stream.Collector<? super T,A,R> collector)`
`<R> R`	`collect(java.util.function.Supplier<R> supplier, java.util.function.BiConsumer<R,? super T> accumulator, java.util.function.BiConsumer<R,R> combiner)`
`long`	`count()`
`java.util.stream.Stream<T>`	`distinct()`
`java.util.stream.Stream<T>`	`filter(java.util.function.Predicate<? super T> predicate)`
`java.util.Optional<T>`	`findAny()`
`java.util.Optional<T>`	`findFirst()`
`<R> java.util.stream.Stream<R>`	`flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)`
`java.util.stream.DoubleStream`	`flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper)`
`java.util.stream.IntStream`	`flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)`
`java.util.stream.LongStream`	`flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper)`
`void`	`forEach(java.util.function.Consumer<? super T> action)`
`void`	`forEachOrdered(java.util.function.Consumer<? super T> action)`
`boolean`	`isParallel()`
`java.util.Iterator<T>`	`iterator()` Get the iterator.
`java.util.stream.Stream<T>`	`limit(long maxSize)`
`<R> java.util.stream.Stream<R>`	`map(java.util.function.Function<? super T,? extends R> mapper)`
`java.util.stream.DoubleStream`	`mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper)`
`java.util.stream.IntStream`	`mapToInt(java.util.function.ToIntFunction<? super T> mapper)`
`java.util.stream.LongStream`	`mapToLong(java.util.function.ToLongFunction<? super T> mapper)`
`java.util.Optional<T>`	`max(java.util.Comparator<? super T> comparator)`
`java.util.Optional<T>`	`min(java.util.Comparator<? super T> comparator)`
`boolean`	`noneMatch(java.util.function.Predicate<? super T> predicate)`
`java.util.stream.Stream<T>`	`onClose(java.lang.Runnable closeHandler)`
`java.util.stream.Stream<T>`	`parallel()`
`java.util.stream.Stream<T>`	`peek(java.util.function.Consumer<? super T> action)`
`java.util.Optional<T>`	`reduce(java.util.function.BinaryOperator<T> accumulator)`
`T`	`reduce(T identity, java.util.function.BinaryOperator<T> accumulator)`
`<U> U`	`reduce(U identity, java.util.function.BiFunction<U,? super T,U> accumulator, java.util.function.BinaryOperator<U> combiner)`
`java.util.stream.Stream<T>`	`sequential()`
`java.util.stream.Stream<T>`	`skip(long n)`
`java.util.stream.Stream<T>`	`sorted()`
`java.util.stream.Stream<T>`	`sorted(java.util.Comparator<? super T> comparator)`
`java.util.Spliterator<T>`	`spliterator()`
`java.lang.Object[]`	`toArray()`
`<A> A[]`	`toArray(java.util.function.IntFunction<A[]> generator)`
`java.util.stream.Stream<T>`	`unordered()`

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

Methods inherited from interface org.lenskit.util.io.ObjectStream
readObject

Methods inherited from interface java.util.stream.Stream
builder, concat, empty, generate, iterate, of, of

- Field Detail
  - stream
```
protected java.util.stream.Stream<T> stream
```
- Constructor Detail
  - AbstractObjectStream
```
public AbstractObjectStream()
```
- Method Detail
  - close
```
public void close()
```
    No-op implementation of the ObjectStream.close() method.
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
    
    Specified by:
    
    close in interface ObjectStream<T>
  - iterator
```
public java.util.Iterator<T> iterator()
```
    Get the iterator. This method just returns this, so for-each loops can be used over streams.
    
    Specified by:
    
    iterator in interface java.lang.Iterable<T>
    
    Specified by:
    
    iterator in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
    
    Returns:
    
    The stream as an iterator.
    
    See Also:
    
    Iterable.iterator()
  - filter
```
public java.util.stream.Stream<T> filter(java.util.function.Predicate<? super T> predicate)
```
    Specified by:
    
    filter in interface java.util.stream.Stream<T>
  - map
```
public <R> java.util.stream.Stream<R> map(java.util.function.Function<? super T,? extends R> mapper)
```
    Specified by:
    
    map in interface java.util.stream.Stream<T>
  - mapToInt
```
public java.util.stream.IntStream mapToInt(java.util.function.ToIntFunction<? super T> mapper)
```
    Specified by:
    
    mapToInt in interface java.util.stream.Stream<T>
  - mapToLong
```
public java.util.stream.LongStream mapToLong(java.util.function.ToLongFunction<? super T> mapper)
```
    Specified by:
    
    mapToLong in interface java.util.stream.Stream<T>
  - mapToDouble
```
public java.util.stream.DoubleStream mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper)
```
    Specified by:
    
    mapToDouble in interface java.util.stream.Stream<T>
  - flatMap
```
public <R> java.util.stream.Stream<R> flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
```
    Specified by:
    
    flatMap in interface java.util.stream.Stream<T>
  - flatMapToInt
```
public java.util.stream.IntStream flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)
```
    Specified by:
    
    flatMapToInt in interface java.util.stream.Stream<T>
  - flatMapToLong
```
public java.util.stream.LongStream flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper)
```
    Specified by:
    
    flatMapToLong in interface java.util.stream.Stream<T>
  - flatMapToDouble
```
public java.util.stream.DoubleStream flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper)
```
    Specified by:
    
    flatMapToDouble in interface java.util.stream.Stream<T>
  - distinct
```
public java.util.stream.Stream<T> distinct()
```
    Specified by:
    
    distinct in interface java.util.stream.Stream<T>
  - sorted
```
public java.util.stream.Stream<T> sorted()
```
    Specified by:
    
    sorted in interface java.util.stream.Stream<T>
  - sorted
```
public java.util.stream.Stream<T> sorted(java.util.Comparator<? super T> comparator)
```
    Specified by:
    
    sorted in interface java.util.stream.Stream<T>
  - peek
```
public java.util.stream.Stream<T> peek(java.util.function.Consumer<? super T> action)
```
    Specified by:
    
    peek in interface java.util.stream.Stream<T>
  - limit
```
public java.util.stream.Stream<T> limit(long maxSize)
```
    Specified by:
    
    limit in interface java.util.stream.Stream<T>
  - skip
```
public java.util.stream.Stream<T> skip(long n)
```
    Specified by:
    
    skip in interface java.util.stream.Stream<T>
  - forEach
```
public void forEach(java.util.function.Consumer<? super T> action)
```
    Specified by:
    
    forEach in interface java.lang.Iterable<T>
    
    Specified by:
    
    forEach in interface java.util.stream.Stream<T>
    
    Specified by:
    
    forEach in interface ObjectStream<T>
  - forEachOrdered
```
public void forEachOrdered(java.util.function.Consumer<? super T> action)
```
    Specified by:
    
    forEachOrdered in interface java.util.stream.Stream<T>
  - toArray
```
public java.lang.Object[] toArray()
```
    Specified by:
    
    toArray in interface java.util.stream.Stream<T>
  - toArray
```
public <A> A[] toArray(java.util.function.IntFunction<A[]> generator)
```
    Specified by:
    
    toArray in interface java.util.stream.Stream<T>
  - reduce
```
public T reduce(T identity,
                java.util.function.BinaryOperator<T> accumulator)
```
    Specified by:
    
    reduce in interface java.util.stream.Stream<T>
  - reduce
```
public java.util.Optional<T> reduce(java.util.function.BinaryOperator<T> accumulator)
```
    Specified by:
    
    reduce in interface java.util.stream.Stream<T>
  - reduce
```
public <U> U reduce(U identity,
                    java.util.function.BiFunction<U,? super T,U> accumulator,
                    java.util.function.BinaryOperator<U> combiner)
```
    Specified by:
    
    reduce in interface java.util.stream.Stream<T>
  - collect
```
public <R> R collect(java.util.function.Supplier<R> supplier,
                     java.util.function.BiConsumer<R,? super T> accumulator,
                     java.util.function.BiConsumer<R,R> combiner)
```
    Specified by:
    
    collect in interface java.util.stream.Stream<T>
  - collect
```
public <R,A> R collect(java.util.stream.Collector<? super T,A,R> collector)
```
    Specified by:
    
    collect in interface java.util.stream.Stream<T>
  - min
```
public java.util.Optional<T> min(java.util.Comparator<? super T> comparator)
```
    Specified by:
    
    min in interface java.util.stream.Stream<T>
  - max
```
public java.util.Optional<T> max(java.util.Comparator<? super T> comparator)
```
    Specified by:
    
    max in interface java.util.stream.Stream<T>
  - count
```
public long count()
```
    Specified by:
    
    count in interface java.util.stream.Stream<T>
  - anyMatch
```
public boolean anyMatch(java.util.function.Predicate<? super T> predicate)
```
    Specified by:
    
    anyMatch in interface java.util.stream.Stream<T>
  - allMatch
```
public boolean allMatch(java.util.function.Predicate<? super T> predicate)
```
    Specified by:
    
    allMatch in interface java.util.stream.Stream<T>
  - noneMatch
```
public boolean noneMatch(java.util.function.Predicate<? super T> predicate)
```
    Specified by:
    
    noneMatch in interface java.util.stream.Stream<T>
  - findFirst
```
public java.util.Optional<T> findFirst()
```
    Specified by:
    
    findFirst in interface java.util.stream.Stream<T>
  - findAny
```
public java.util.Optional<T> findAny()
```
    Specified by:
    
    findAny in interface java.util.stream.Stream<T>
  - spliterator
```
public java.util.Spliterator<T> spliterator()
```
    Specified by:
    
    spliterator in interface java.lang.Iterable<T>
    
    Specified by:
    
    spliterator in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
    
    Specified by:
    
    spliterator in interface ObjectStream<T>
  - isParallel
```
public boolean isParallel()
```
    Specified by:
    
    isParallel in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
  - sequential
```
public java.util.stream.Stream<T> sequential()
```
    Specified by:
    
    sequential in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
  - parallel
```
public java.util.stream.Stream<T> parallel()
```
    Specified by:
    
    parallel in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
  - unordered
```
public java.util.stream.Stream<T> unordered()
```
    Specified by:
    
    unordered in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
  - onClose
```
public java.util.stream.Stream<T> onClose(java.lang.Runnable closeHandler)
```
    Specified by:
    
    onClose in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

Class AbstractObjectStream<T>

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.Stream

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.lenskit.util.io.ObjectStream

Methods inherited from interface java.util.stream.Stream

Field Detail

stream

Constructor Detail

AbstractObjectStream

Method Detail

close

iterator

filter

map

mapToInt

mapToLong

mapToDouble

flatMap

flatMapToInt

flatMapToLong

flatMapToDouble

distinct

sorted

sorted

peek

limit

skip

forEach

forEachOrdered

toArray

toArray

reduce

reduce

reduce

collect

collect

min

max

count

anyMatch

allMatch

noneMatch

findFirst

findAny

spliterator

isParallel

sequential

parallel

unordered

onClose