Package eu.simuline.octave.exec

Class OctaveWriterCallable

java.lang.Object

eu.simuline.octave.exec.OctaveWriterCallable

All Implemented Interfaces:

Callable<Void>

final class OctaveWriterCallable
extends Object
implements Callable<Void>

Callable that writes scripts to the octave process. Used in OctaveExec.evalRW(WriteFunctor, ReadFunctor) only. This is complementary to OctaveReaderCallable.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.commons.logging.Log	LOG
(package private) static String	MSG_IOE_SPACER
(package private) static String	MSG_IOE_WRITE
private Writer	processWriter	The writer for scripts passed to octave.
private String	spacer	A string essentially consisting of a unique hashvalue.
private WriteFunctor	writeFunctor	The functor the writing task is delegated to.

Constructor Summary

Constructors

Constructor	Description
OctaveWriterCallable(Writer processWriter, WriteFunctor writeFunctor, String spacer)	Creates a new OctaveWriterCallable with method call() delegating writing

Method Summary

Modifier and Type	Method	Description
Void	call()	Calling writes to processWriter representing the octave process: first according to writeFunctor, i.e. delegates to WriteFunctor.doWrites(Writer), then writes printf of spacer and then flush.

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_WRITE

static final String MSG_IOE_WRITE

See Also:

Constant Field Values

MSG_IOE_SPACER

static final String MSG_IOE_SPACER

See Also:

Constant Field Values

processWriter

private final Writer processWriter

The writer for scripts passed to octave. This is nothing but OctaveExec.processWriter.

writeFunctor

private final WriteFunctor writeFunctor

The functor the writing task is delegated to.

spacer

private final String spacer

A string essentially consisting of a unique hashvalue. It is printed to processWriter after having applied writeFunctor. That way the according OctaveReaderCallable detects the end of the read sequence from the octave process.

Constructor Detail

OctaveWriterCallable

OctaveWriterCallable(Writer processWriter,
                     WriteFunctor writeFunctor,
                     String spacer)

Creates a new OctaveWriterCallable with method call() delegating writing

Parameters:

processWriter - the writer used for writing.

writeFunctor - the functor the writing process is delegated to.

spacer - a string essentially consisting of a unique hashvalue printed after applying the write functor. This indicates the end of the sunbsequent according reading process in OctaveExec.evalRW(WriteFunctor, ReadFunctor).

Method Detail

call

public Void call()

Calling writes to processWriter representing the octave process: first according to writeFunctor, i.e. delegates to WriteFunctor.doWrites(Writer), then writes printf of spacer and then flush. That way, OctaveReaderCallable.call() knows, that reading is completed, as soon as the spacer is detected. Exceptions are logged on LOG.

Specified by:

call in interface Callable<Void>

Throws:

OctaveIOException - if the underlying writeFunctor or processWriter throws an IOException.