com.lts.ipc.fifo
Class FIFOInputStream

java.lang.Object
  java.io.InputStream
      com.lts.ipc.fifo.FIFOInputStream

All Implemented Interfaces:

java.io.Closeable

public class FIFOInputStream
extends java.io.InputStream

Constructor Summary

FIFOInputStream(FIFO pipe)

FIFOInputStream(FIFO fifo, int timeoutMsec)

Method Summary

protected int	bytesAvailable()
protected void	initialize(FIFO pipe, int timeoutMsec)
boolean	isEndOfFile()
protected void	loadBuffer()
int	read()
int	read(byte[] buffer, int offset, int length)
void	setEndOfFile(boolean endOfFile)

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

FIFOInputStream

public FIFOInputStream(FIFO pipe)

FIFOInputStream

public FIFOInputStream(FIFO fifo,
                       int timeoutMsec)

Method Detail

isEndOfFile

public boolean isEndOfFile()

setEndOfFile

public void setEndOfFile(boolean endOfFile)

initialize

protected void initialize(FIFO pipe,
                          int timeoutMsec)

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

bytesAvailable

protected int bytesAvailable()

read

public int read(byte[] buffer,
                int offset,
                int length)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

loadBuffer

protected void loadBuffer()
                   throws java.io.IOException

Throws:

java.io.IOException