Class TimedReader

Method Details

• getMaxTime

  public long getMaxTime()

  Returns the maximum reading time in milliseconds, measured from open().

• open

  public void open() throws DataException

  Description copied from class: DataEndpoint

  Makes this endpoint ready for reading or writing.

  Overrides:

  open in class ProxyReader

  Throws:

  DataException

• close

  public void close() throws DataException

  Description copied from class: DataEndpoint

  Indicates that this endpoint has finished reading or writing.

  Overrides:

  close in class ProxyReader

  Throws:

  DataException

• read

  public Record read()

  Description copied from class: DataReader

  Reads the next record from this DataReader and increases the record-count by 1. This method will first read any pushed (DataReader.push(Record)) records before reading from the underlying source.

  If no record is available, null will be returned. This method blocks until a record is available, the end of the stream is reached, or an exception is thrown.

  Any exception raised while reading will be converted to a DataException using DataObject.exception(Throwable).

  Subclasses generally do not need to override this method, instead they should implement DataReader.readImpl().

  Overrides:

  read in class DataReader

  See Also:

  • DataReader.push(Record)
  • DataReader.peek(int)
  • DataReader.read()

• addExceptionProperties

  public DataException addExceptionProperties(DataException exception)

  Description copied from class: Endpoint

  Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.

  Overrides:

  addExceptionProperties in class ProxyReader

• toString

  public String toString()

  Overrides:

  toString in class DataEndpoint

• isTimeExpired

  public boolean isTimeExpired()

  Returns true if reading stopped due to the time expiring.