Package one.nio.serial

Class ObjectInputChannel

java.lang.Object

one.nio.serial.DataStream

one.nio.serial.ObjectInputChannel

All Implemented Interfaces:

DataInput, DataOutput, ObjectInput, ObjectOutput, AutoCloseable

public class ObjectInputChannel
extends DataStream

Field Summary

Fields

Modifier and Type	Field	Description
private long	bytesRead
private int	capacity
private final ReadableByteChannel	ch
private Object[]	context
private int	contextSize
private static final Object[]	EMPTY_CONTEXT
private static final int	INITIAL_CAPACITY

Fields inherited from class one.nio.serial.DataStream

address, array, FIRST_BOOT_UID, limit, offset, REF_EMBEDDED, REF_NULL, REF_RECURSIVE, REF_RECURSIVE2

Constructor Summary

Constructors

Constructor	Description
ObjectInputChannel(ReadableByteChannel ch)
ObjectInputChannel(ReadableByteChannel ch, int bufSize)

Method Summary

Modifier and Type	Method	Description
protected long	alloc(int size)
void	close()
private void	fetch(int size)
long	getBytesRead()
Object	readObject()
void	register(Object obj)
void	reset()

Methods inherited from class one.nio.serial.DataStream

address, array, available, byteBuffer, count, flush, newScope, read, read, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readRef, readShort, readTo, readUnsignedByte, readUnsignedShort, readUTF, skip, skipBytes, write, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeFrom, writeInt, writeLong, writeObject, writeShort, writeUTF

Methods inherited from class java.lang.Object

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

Field Details

EMPTY_CONTEXT

private static final Object[] EMPTY_CONTEXT

INITIAL_CAPACITY

private static final int INITIAL_CAPACITY

See Also:

• Constant Field Values

ch

private final ReadableByteChannel ch

capacity

private int capacity

context

private Object[] context

contextSize

private int contextSize

bytesRead

private long bytesRead

Constructor Details

ObjectInputChannel

public ObjectInputChannel(ReadableByteChannel ch)

ObjectInputChannel

public ObjectInputChannel(ReadableByteChannel ch,
 int bufSize)

Method Details

getBytesRead

public long getBytesRead()

readObject

public Object readObject()
                  throws IOException,
ClassNotFoundException

Specified by:

readObject in interface ObjectInput

Overrides:

readObject in class DataStream

Throws:

IOException

ClassNotFoundException

reset

public void reset()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ObjectInput

Specified by:

close in interface ObjectOutput

Overrides:

close in class DataStream

Throws:

IOException

register

public void register(Object obj)

Overrides:

register in class DataStream

alloc

protected long alloc(int size)
              throws IOException

Overrides:

alloc in class DataStream

Throws:

IOException

fetch

private void fetch(int size)
            throws IOException

Throws:

IOException