eu.simuline.octave.exec

Class OctaveExecuteReader

java.lang.Object

java.io.Reader

eu.simuline.octave.exec.OctaveExecuteReader

All Implemented Interfaces:

Closeable, AutoCloseable, Readable

final class OctaveExecuteReader
extends Reader

Reader that passes the reading on to the output from the octave process until the spacer reached, then it returns EOF. When this reader is closed the underlying reader is slurped up to the spacer.

Field Summary

Fields

Modifier and Type	Field and Description
private StringBuffer	buffer The current line read from octaveReader but not yet passed to a char-array by read(char[], int, int).
private boolean	eof Whether end of reader found.
private boolean	firstLine Whether reading the first line.
private static org.apache.commons.logging.Log	LOG
private BufferedReader	octaveReader The wrapped reader.
private String	spacer The string signifying end of stream.

Fields inherited from class java.io.Reader

lock

Constructor Summary

Constructors

Constructor and Description
OctaveExecuteReader(BufferedReader octaveReader, String spacer) This reader will read from octaveReader until a single line equal() spacer is read, after that this reader will return eof.

Method Summary

Modifier and Type	Method and Description
void	close()
int	read(char[] cbuf, int off, int len) Reads characters into a portion of an array.

Methods inherited from class java.io.Reader

mark, markSupported, read, read, read, ready, reset, skip

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

octaveReader

private final BufferedReader octaveReader

The wrapped reader.

spacer

private final String spacer

The string signifying end of stream.

buffer

private StringBuffer buffer

The current line read from octaveReader but not yet passed to a char-array by read(char[], int, int). If this buffer were empty, it is null instead, which is also the initial value. If this is not the first line, the line read from octaveReader is preceeded by newline before being passed to buffer.

firstLine

private boolean firstLine

Whether reading the first line. Initially, this is true. It is set to false, by read(char[], int, int) if buffer is filled for the first time.

eof

private boolean eof

Whether end of reader found. Initially, this is false. It is set to false, by read(char[], int, int) if buffer equals spacer, not really end of octaveReader.

Constructor Detail

OctaveExecuteReader

OctaveExecuteReader(BufferedReader octaveReader,
                    String spacer)

This reader will read from octaveReader until a single line equal() spacer is read, after that this reader will return eof. When this reader is closed it will update the state of octave to NONE.

Parameters:

octaveReader - the wrapped reader

spacer - the line signifying end of stream.

Method Detail

read

public int read(char[] cbuf,
                int off,
                int len)
         throws IOException

Reads characters into a portion of an array. This method will block until some input is available, an I/O error occurs, or the end of the stream is reached.

Specified by:

read in class Reader

Parameters:

cbuf - Destination buffer

off - Offset at which to start storing characters.

len - Maximum number of characters to read.

Returns:

The number of characters read, or -1 if the end of the stream has been reached. The latter is the case if eof is set which means that line spacer has been found.

Throws:

IOException - If an I/O error occurs. This is true in particular, if null-line has been read from octaveReader.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class Reader

Throws:

IOException