T
- the type of the stream elements.S
- the type of the IO stream extending IOBaseStream
.B
- the type of the stream extending BaseStream
.public interface IOBaseStream<T,S extends IOBaseStream<T,S,B>,B extends BaseStream<T,B>> extends Closeable
BaseStream
but throws IOException
.Modifier and Type | Method and Description |
---|---|
default BaseStream<T,B> |
asBaseStream()
|
default void |
close()
Like
BaseStream.close() . |
default boolean |
isParallel()
Like
BaseStream.isParallel() . |
default IOIterator<T> |
iterator()
Like
BaseStream.iterator() . |
default S |
onClose(IORunnable closeHandler)
|
default S |
parallel()
Like
BaseStream.parallel() . |
default S |
sequential()
Like
BaseStream.sequential() . |
default IOSpliterator<T> |
spliterator()
Like
BaseStream.spliterator() . |
default S |
unordered()
Like
BaseStream.unordered() . |
B |
unwrap()
Unwraps this instance and returns the underlying
Stream . |
S |
wrap(B delegate)
Wraps a
Stream . |
default BaseStream<T,B> asBaseStream()
UncheckedIOException
BaseStream
.default void close()
BaseStream.close()
.close
in interface AutoCloseable
close
in interface Closeable
BaseStream.close()
default boolean isParallel()
BaseStream.isParallel()
.delegate
.BaseStream.isParallel()
default IOIterator<T> iterator()
BaseStream.iterator()
.delegate
.BaseStream.iterator()
default S onClose(IORunnable closeHandler) throws IOException
closeHandler
- See delegate
.delegate
.IOException
- if an I/O error occurs.BaseStream.onClose(Runnable)
default S parallel()
BaseStream.parallel()
.delegate
.BaseStream.parallel()
default S sequential()
BaseStream.sequential()
.delegate
.BaseStream.sequential()
default IOSpliterator<T> spliterator()
BaseStream.spliterator()
.delegate
.BaseStream.spliterator()
default S unordered()
BaseStream.unordered()
.delegate
.BaseStream.unordered()
B unwrap()
Stream
.
Implementations may not have anything to unwrap and that behavior is undefined for now.
Copyright © 2002–2023 The Apache Software Foundation. All rights reserved.