Module id.kineticstreamer

Package id.kineticstreamer.streams

Class ByteInputKineticStream

Object

ByteInputKineticStream

All Implemented Interfaces:

InputKineticStream, AutoCloseable

public class ByteInputKineticStream
extends Object
implements InputKineticStream

Kinetic stream implementation for deserialization of Java objects into sequence of bytes.

Constructor Summary

Constructors

Constructor	Description
ByteInputKineticStream(DataInput in)	Creates byte kinetic stream and attaches it to 'in'

Method Summary

Modifier and Type	Method	Description
void	close()
Object[]	readArray(Class<?> type)
boolean	readBool()
boolean[]	readBooleanArray()
byte	readByte()
byte[]	readByteArray()
double	readDouble()
double[]	readDoubleArray()
float	readFloat()
int	readInt()
int[]	readIntArray()
String	readString()

Methods inherited from class Object

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

Constructor Detail

ByteInputKineticStream

public ByteInputKineticStream(DataInput in)

Creates byte kinetic stream and attaches it to 'in'

Method Detail

readString

public String readString()
                  throws IOException

Specified by:

readString in interface InputKineticStream

Throws:

IOException

readInt

public int readInt()
            throws IOException

Specified by:

readInt in interface InputKineticStream

Throws:

IOException

readFloat

public float readFloat()
                throws IOException

Specified by:

readFloat in interface InputKineticStream

Throws:

IOException

readDouble

public double readDouble()
                  throws IOException

Specified by:

readDouble in interface InputKineticStream

Throws:

IOException

readBool

public boolean readBool()
                 throws IOException

Specified by:

readBool in interface InputKineticStream

Throws:

IOException

readArray

public Object[] readArray(Class<?> type)
                   throws Exception

Specified by:

readArray in interface InputKineticStream

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

readByte

public byte readByte()
              throws Exception

Specified by:

readByte in interface InputKineticStream

Throws:

Exception

readIntArray

public int[] readIntArray()
                   throws Exception

Specified by:

readIntArray in interface InputKineticStream

Throws:

Exception

readByteArray

public byte[] readByteArray()
                     throws Exception

Specified by:

readByteArray in interface InputKineticStream

Throws:

Exception

readDoubleArray

public double[] readDoubleArray()
                         throws Exception

Specified by:

readDoubleArray in interface InputKineticStream

Throws:

Exception

readBooleanArray

public boolean[] readBooleanArray()
                           throws Exception

Specified by:

readBooleanArray in interface InputKineticStream

Throws:

Exception