Class AbstractEventStream<T>

    • Constructor Detail

      • AbstractEventStream

        public AbstractEventStream​(ObjectStream<T> samples)
        Initializes the current instance with a sample Iterator.
        Parameters:
        samples - the sample Iterator.
    • Method Detail

      • read

        public final Event read()
                         throws IOException
        Description copied from interface: ObjectStream
        Returns the next object. Calling this method repeatedly until it returns null will return each object from the underlying source exactly once.
        Specified by:
        read in interface ObjectStream<T>
        Returns:
        the next object or null to signal that the stream is exhausted
        Throws:
        IOException - if there is an error during reading
      • close

        public void close()
                   throws IOException
        Description copied from interface: ObjectStream
        Closes the ObjectStream and releases all allocated resources. After close was called its not allowed to call read or reset.
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface ObjectStream<T>
        Throws:
        IOException - if there is an error during closing the stream