public static class DataStreams.DataStreamDecoder<T>
extends java.lang.Object
implements java.util.Iterator<T>
InputStream
to an Iterator
of T
values
using the specified Coder
.
Note that this adapter follows the Beam Fn API specification for forcing values that decode consuming zero bytes to consuming exactly one byte.
Note that access to the underlying InputStream
is lazy and will only be invoked on
first access to next()
or hasNext()
.
Constructor and Description |
---|
DataStreamDecoder(Coder<T> coder,
java.io.InputStream inputStream) |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
T |
next() |
void |
remove() |