org.shoal.ha.cache.impl.util
Class ReplicationInputStream

java.lang.Object
  java.io.InputStream
      java.io.ByteArrayInputStream
          org.shoal.ha.cache.impl.util.ReplicationInputStream

All Implemented Interfaces:

java.io.Closeable

public class ReplicationInputStream
extends java.io.ByteArrayInputStream

Author:

Mahesh Kannan

Field Summary

Fields inherited from class java.io.ByteArrayInputStream

buf, count, mark, pos

Constructor Summary

ReplicationInputStream(byte[] data)

ReplicationInputStream(byte[] data, int offset, int len)

Method Summary

byte[]	getBuffer()
int	mark()
boolean	readBoolean()
int	readInt()
byte[]	readLengthPrefixedBytes()
java.lang.String	readLengthPrefixedString()
long	readLong()
void	skipTo(int index)

Methods inherited from class java.io.ByteArrayInputStream

available, close, mark, markSupported, read, read, reset, skip

Methods inherited from class java.io.InputStream

read

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationInputStream

public ReplicationInputStream(byte[] data)

ReplicationInputStream

public ReplicationInputStream(byte[] data,
                              int offset,
                              int len)

Method Detail

mark

public int mark()

skipTo

public void skipTo(int index)

readInt

public final int readInt()

readLong

public final long readLong()

readLengthPrefixedString

public final java.lang.String readLengthPrefixedString()

readLengthPrefixedBytes

public final byte[] readLengthPrefixedBytes()

readBoolean

public boolean readBoolean()

getBuffer

public byte[] getBuffer()