E - public class EventObjectInputStream<E>
extends java.io.InputStream
| Modifier and Type | Field and Description |
|---|---|
(package private) java.util.List<E> |
buffer |
(package private) int |
index |
(package private) NonClosableInputStream |
ncis |
| Constructor and Description |
|---|
EventObjectInputStream(java.io.InputStream is) |
| Modifier and Type | Method and Description |
|---|---|
int |
available()
Returns the number of bytes available
|
void |
close() |
(package private) E |
getFromBuffer() |
private void |
internalReset() |
int |
read() |
E |
readEvent() |
(package private) E |
readEvents(java.io.ObjectInputStream ois) |
(package private) void |
readFooter(int count) |
(package private) int |
readHeader() |
(package private) void |
readPayload(int count) |
NonClosableInputStream ncis
java.util.List<E> buffer
int index
EventObjectInputStream(java.io.InputStream is)
throws java.io.IOException
java.io.IOExceptionpublic int read()
throws java.io.IOException
read in class java.io.InputStreamjava.io.IOExceptionpublic int available()
throws java.io.IOException
available in class java.io.InputStreamjava.io.IOExceptionpublic E readEvent() throws java.io.IOException
java.io.IOExceptionprivate void internalReset()
E getFromBuffer()
int readHeader()
throws java.io.IOException
java.io.IOExceptionE readEvents(java.io.ObjectInputStream ois) throws java.io.IOException
java.io.IOExceptionvoid readFooter(int count)
throws java.io.IOException
java.io.IOExceptionvoid readPayload(int count)
throws java.io.IOException
java.io.IOExceptionpublic void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in class java.io.InputStreamjava.io.IOException