com.orientechnologies.orient.core.serialization

Class OMemoryInputStream

java.lang.Object

java.io.InputStream

com.orientechnologies.orient.core.serialization.OMemoryInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class OMemoryInputStream
extends InputStream

Class to parse and write buffers in very fast way.

Author:

Luca Garulli

Constructor Summary

Constructors

Constructor and Description
OMemoryInputStream()
OMemoryInputStream(byte[] iBuffer)
OMemoryInputStream(byte[] iBuffer, int iOffset, int iLength)

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
byte[]	copy()
boolean	getAsBoolean()
byte	getAsByte()
byte[]	getAsByteArray()
byte[]	getAsByteArray(int iOffset)
byte[]	getAsByteArrayFixed(int iSize)
int	getAsByteArrayOffset() Browse the stream but just return the begin of the byte array.
char	getAsChar()
int	getAsInteger()
long	getAsLong()
short	getAsShort()
int	getPosition()
int	getSize()
int	getVariableSize()
OMemoryInputStream	jump(int iOffset)
byte	peek()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	reset()
void	setSource(byte[] iBuffer)
void	setSource(byte[] iBuffer, int iOffset, int iLength)

Methods inherited from class java.io.InputStream

mark, markSupported, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

OMemoryInputStream

public OMemoryInputStream()

OMemoryInputStream

public OMemoryInputStream(byte[] iBuffer)

OMemoryInputStream

public OMemoryInputStream(byte[] iBuffer,
                          int iOffset,
                          int iLength)

Method Detail

getAsByteArrayFixed

public byte[] getAsByteArrayFixed(int iSize)
                           throws IOException

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

getAsByteArrayOffset

public int getAsByteArrayOffset()

Browse the stream but just return the begin of the byte array. This is used to lazy load the information only when needed.

read

public int read()
         throws IOException

Specified by:

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(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

getAsByteArray

public byte[] getAsByteArray(int iOffset)
                      throws IOException

Throws:

IOException

getAsByteArray

public byte[] getAsByteArray()
                      throws IOException

Throws:

IOException

getAsBoolean

public boolean getAsBoolean()
                     throws IOException

Throws:

IOException

getAsChar

public char getAsChar()
               throws IOException

Throws:

IOException

getAsByte

public byte getAsByte()
               throws IOException

Throws:

IOException

getAsLong

public long getAsLong()
               throws IOException

Throws:

IOException

getAsInteger

public int getAsInteger()
                 throws IOException

Throws:

IOException

getAsShort

public short getAsShort()
                 throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

peek

public byte peek()

setSource

public void setSource(byte[] iBuffer)

setSource

public void setSource(byte[] iBuffer,
                      int iOffset,
                      int iLength)

jump

public OMemoryInputStream jump(int iOffset)

copy

public byte[] copy()

getVariableSize

public int getVariableSize()
                    throws IOException

Throws:

IOException

getSize

public int getSize()

getPosition

public int getPosition()

reset

public void reset()
           throws IOException

Overrides:

reset in class InputStream

Throws:

IOException