xyz.cofe.ipc.sharedmem

Class ByteQueue.InStream

java.lang.Object

java.io.InputStream

xyz.cofe.ipc.sharedmem.ByteQueue.InStream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ByteQueue

public static class ByteQueue.InStream
extends InputStream

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteQueue	byteQueue
protected byte[]	data
protected long	delay
protected int	pointer
protected int	readTimeout

Constructor Summary

Constructors

Constructor and Description
InStream(ByteQueue byteQueue)

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
ByteQueue	getByteQueue()
long	getDelay() Указывает задержку в цикле чтения данных в нано секундах.
int	getReadTimeout() Указывает максимальное время ожидания поступления данных
boolean	isClosed()
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
protected byte[]	readData()
void	setDelay(long d) Указывает задержку в цикле чтения данных в нано секундах.
void	setReadTimeout(int readTimeout) Указывает максимальное время ожидания поступления данных

Methods inherited from class java.io.InputStream

mark, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

byteQueue

protected ByteQueue byteQueue

data

protected byte[] data

pointer

protected int pointer

readTimeout

protected int readTimeout

delay

protected long delay

Constructor Detail

InStream

public InStream(ByteQueue byteQueue)

Method Detail

getReadTimeout

public int getReadTimeout()

Указывает максимальное время ожидания поступления данных

Returns:

макс. время ожидания в милисекундах или -1 - бесколнечно

setReadTimeout

public void setReadTimeout(int readTimeout)

Указывает максимальное время ожидания поступления данных

Parameters:

readTimeout - макс. время ожидания в милисекундах или -1 - бесколнечно

getByteQueue

public ByteQueue getByteQueue()

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

isClosed

public boolean isClosed()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

getDelay

public long getDelay()

Указывает задержку в цикле чтения данных в нано секундах. По умолчанию 10000.
0 - без задержки, -1 - поток передает управление yeild()

Returns:

задержка

setDelay

public void setDelay(long d)

Указывает задержку в цикле чтения данных в нано секундах. По умолчанию 10000.
0 - без задержки, -1 - поток передает управление yeild()

Parameters:

d - задержка

readData

protected byte[] readData()

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException