Package eu.simuline.octave.exec

Class OctaveReaderCallable

java.lang.Object

eu.simuline.octave.exec.OctaveReaderCallable

All Implemented Interfaces:

Callable<Void>

final class OctaveReaderCallable
extends Object
implements Callable<Void>

Callable that reads from the octave process. Used in OctaveExec.evalRW(WriteFunctor, ReadFunctor) only. This is complementary to OctaveWriterCallable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	OctaveReaderCallable.OctaveExecuteReader	Reader that passes the reading on to the output from the octave process, i.e. from processReader until the spacer spacer reached, then it returns EOF.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.commons.logging.Log	LOG
private static String	MSG_IOE_CLS
private static String	MSG_IOE_READ
private BufferedReader	processReader	The reader for feedback on scripts received from octave.
private ReadFunctor	readFunctor	The functor the reading task is delegated to.
private String	spacer	A string essentially consisting of a unique hashvalue.

Constructor Summary

Constructors

Constructor	Description
OctaveReaderCallable(BufferedReader processReader, ReadFunctor readFunctor, String spacer)

Method Summary

Modifier and Type	Method	Description
Void	call()	Calling essentially reads from processReader representing the octave process: Reads until spacer is detected which is not really read but is interpreted as an eof symbol.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

MSG_IOE_READ

private static final String MSG_IOE_READ

See Also:

Constant Field Values

MSG_IOE_CLS

private static final String MSG_IOE_CLS

See Also:

Constant Field Values

processReader

private final BufferedReader processReader

The reader for feedback on scripts received from octave. This is nothing but OctaveExec.processReader.

readFunctor

private final ReadFunctor readFunctor

The functor the reading task is delegated to.

spacer

private final String spacer

A string essentially consisting of a unique hashvalue. It has been printed by the according OctaveWriterCallable after having applied the write functor and thus indicates the end of the read sequence of the octave process.

Constructor Detail

OctaveReaderCallable

OctaveReaderCallable(BufferedReader processReader,
                     ReadFunctor readFunctor,
                     String spacer)

Parameters:

processReader - the reader used for reading.

readFunctor - the functor the reading process is delegated to.

spacer - a string essentially consisting of a unique hashvalue printed at the end of the according write process in OctaveExec.evalRW(WriteFunctor, ReadFunctor) and thus signifying the end of the sequence to be read.

Method Detail

call

public Void call()

Calling essentially reads from processReader representing the octave process: Reads until spacer is detected which is not really read but is interpreted as an eof symbol. To that end, processReader is wrapped into an OctaveReaderCallable.OctaveExecuteReader with parameter spacer which yields eof if the spacer is detected. Closing the OctaveReaderCallable.OctaveExecuteReader reads the spacer without passing it further. Exceptions are logged on LOG.

Specified by:

call in interface Callable<Void>

Throws:

OctaveIOException - if underlying readFunctor or the reader processReader or the wrapping OctaveReaderCallable.OctaveExecuteReader throws an IOException.