public abstract class AbstractEventStream<T> extends Object implements ObjectStream<Event>
Constructor and Description |
---|
AbstractEventStream(ObjectStream<T> samples)
Initializes the current instance with a sample
Iterator . |
public AbstractEventStream(ObjectStream<T> samples)
Iterator
.samples
- the sample Iterator
.public final Event read() throws IOException
ObjectStream
read
in interface ObjectStream<Event>
IOException
- if there is an error during readingpublic void reset() throws IOException, UnsupportedOperationException
ObjectStream
reset
in interface ObjectStream<Event>
IOException
- if there is an error during reseting the streamUnsupportedOperationException
public void close() throws IOException
ObjectStream
ObjectStream
and releases all allocated
resources. After close was called its not allowed to call
read or reset.close
in interface AutoCloseable
close
in interface ObjectStream<Event>
IOException
- if there is an error during closing the streamCopyright © 2015 The Apache Software Foundation. All rights reserved.