public class BasicStream
extends java.lang.Object
| Constructor and Description |
|---|
BasicStream(Instance instance,
EncodingVersion encoding) |
BasicStream(Instance instance,
EncodingVersion encoding,
boolean direct) |
BasicStream(Instance instance,
EncodingVersion encoding,
byte[] data) |
BasicStream(Instance instance,
EncodingVersion encoding,
java.nio.ByteBuffer data) |
| Modifier and Type | Method and Description |
|---|---|
void |
clear() |
java.lang.Object |
closure() |
java.lang.Object |
closure(java.lang.Object p) |
BasicStream |
compress(int headerSize,
int compressionLevel) |
static boolean |
compressible() |
void |
endReadEncaps() |
void |
endReadEncapsChecked() |
SlicedData |
endReadException(boolean preserve) |
SlicedData |
endReadObject(boolean preserve) |
void |
endReadSlice() |
void |
endSize(int pos) |
void |
endWriteEncaps() |
void |
endWriteEncapsChecked() |
void |
endWriteException() |
void |
endWriteObject() |
void |
endWriteSlice() |
void |
expand(int n) |
Buffer |
getBuffer() |
int |
getReadEncapsSize() |
EncodingVersion |
getReadEncoding() |
EncodingVersion |
getWriteEncoding() |
Instance |
instance() |
boolean |
isEmpty() |
int |
pos() |
void |
pos(int n) |
Buffer |
prepareWrite() |
int |
readAndCheckSeqSize(int minSize) |
byte[] |
readBlob(int sz) |
boolean |
readBool() |
void |
readBool(int tag,
BooleanOptional v) |
boolean[] |
readBoolSeq() |
void |
readBoolSeq(int tag,
Optional<boolean[]> v) |
byte |
readByte() |
void |
readByte(int tag,
ByteOptional v) |
java.nio.ByteBuffer |
readByteBuffer() |
byte[] |
readByteSeq() |
void |
readByteSeq(int tag,
Optional<byte[]> v) |
double |
readDouble() |
void |
readDouble(int tag,
DoubleOptional v) |
java.nio.DoubleBuffer |
readDoubleBuffer() |
double[] |
readDoubleSeq() |
void |
readDoubleSeq(int tag,
Optional<double[]> v) |
byte[] |
readEncaps(EncodingVersion encoding) |
int |
readEnum(int maxValue) |
float |
readFloat() |
void |
readFloat(int tag,
FloatOptional v) |
java.nio.FloatBuffer |
readFloatBuffer() |
float[] |
readFloatSeq() |
void |
readFloatSeq(int tag,
Optional<float[]> v) |
int |
readInt() |
void |
readInt(int tag,
IntOptional v) |
java.nio.IntBuffer |
readIntBuffer() |
int[] |
readIntSeq() |
void |
readIntSeq(int tag,
Optional<int[]> v) |
long |
readLong() |
void |
readLong(int tag,
LongOptional v) |
java.nio.LongBuffer |
readLongBuffer() |
long[] |
readLongSeq() |
void |
readLongSeq(int tag,
Optional<long[]> v) |
void |
readObject(int tag,
Optional<Object> v) |
void |
readObject(Patcher patcher) |
boolean |
readOpt(int tag,
OptionalFormat expectedFormat) |
boolean |
readOptImpl(int readTag,
OptionalFormat expectedFormat) |
void |
readPendingObjects() |
ObjectPrx |
readProxy() |
void |
readProxy(int tag,
Optional<ObjectPrx> v) |
java.io.Serializable |
readSerializable() |
short |
readShort() |
void |
readShort(int tag,
ShortOptional v) |
java.nio.ShortBuffer |
readShortBuffer() |
short[] |
readShortSeq() |
void |
readShortSeq(int tag,
Optional<short[]> v) |
int |
readSize() |
java.lang.String |
readString() |
void |
readString(int tag,
Optional<java.lang.String> v) |
java.lang.String[] |
readStringSeq() |
void |
readStringSeq(int tag,
Optional<java.lang.String[]> v) |
void |
reset() |
void |
resetEncaps() |
void |
resize(int sz,
boolean reading) |
void |
rewriteBool(boolean v,
int dest) |
void |
rewriteByte(byte v,
int dest) |
void |
rewriteInt(int v,
int dest) |
int |
size() |
void |
skip(int size) |
EncodingVersion |
skipEmptyEncaps() |
EncodingVersion |
skipEncaps() |
void |
skipOpt(OptionalFormat format) |
void |
skipOpts() |
void |
skipSize() |
void |
skipSlice() |
void |
sliceObjects(boolean b) |
EncodingVersion |
startReadEncaps() |
void |
startReadException() |
void |
startReadObject() |
java.lang.String |
startReadSlice() |
int |
startSize() |
void |
startWriteEncaps() |
void |
startWriteEncaps(EncodingVersion encoding,
FormatType format) |
void |
startWriteException(SlicedData data) |
void |
startWriteObject(SlicedData data) |
void |
startWriteSlice(java.lang.String typeId,
int compactId,
boolean last) |
void |
swap(BasicStream other) |
void |
throwException(UserExceptionFactory factory) |
BasicStream |
uncompress(int headerSize,
int messageSizeMax) |
void |
writeBlob(byte[] v) |
void |
writeBlob(byte[] v,
int off,
int len) |
void |
writeBool(boolean v) |
void |
writeBool(int tag,
boolean v) |
void |
writeBool(int tag,
BooleanOptional v) |
void |
writeBoolSeq(boolean[] v) |
void |
writeBoolSeq(int tag,
boolean[] v) |
void |
writeBoolSeq(int tag,
Optional<boolean[]> v) |
void |
writeByte(byte v) |
void |
writeByte(int tag,
byte v) |
void |
writeByte(int tag,
ByteOptional v) |
void |
writeByteBuffer(java.nio.ByteBuffer v) |
void |
writeByteSeq(byte[] v) |
void |
writeByteSeq(int tag,
byte[] v) |
void |
writeByteSeq(int tag,
Optional<byte[]> v) |
void |
writeDouble(double v) |
void |
writeDouble(int tag,
double v) |
void |
writeDouble(int tag,
DoubleOptional v) |
void |
writeDoubleBuffer(java.nio.DoubleBuffer v) |
void |
writeDoubleSeq(double[] v) |
void |
writeDoubleSeq(int tag,
double[] v) |
void |
writeDoubleSeq(int tag,
Optional<double[]> v) |
void |
writeEmptyEncaps(EncodingVersion encoding) |
void |
writeEncaps(byte[] v) |
void |
writeEnum(int v,
int maxValue) |
void |
writeFloat(float v) |
void |
writeFloat(int tag,
float v) |
void |
writeFloat(int tag,
FloatOptional v) |
void |
writeFloatBuffer(java.nio.FloatBuffer v) |
void |
writeFloatSeq(float[] v) |
void |
writeFloatSeq(int tag,
float[] v) |
void |
writeFloatSeq(int tag,
Optional<float[]> v) |
void |
writeInt(int v) |
void |
writeInt(int tag,
int v) |
void |
writeInt(int tag,
IntOptional v) |
void |
writeIntBuffer(java.nio.IntBuffer v) |
void |
writeIntSeq(int[] v) |
void |
writeIntSeq(int tag,
int[] v) |
void |
writeIntSeq(int tag,
Optional<int[]> v) |
void |
writeLong(int tag,
long v) |
void |
writeLong(int tag,
LongOptional v) |
void |
writeLong(long v) |
void |
writeLongBuffer(java.nio.LongBuffer v) |
void |
writeLongSeq(int tag,
long[] v) |
void |
writeLongSeq(int tag,
Optional<long[]> v) |
void |
writeLongSeq(long[] v) |
void |
writeObject(int tag,
Object v) |
<T extends Object> |
writeObject(int tag,
Optional<T> v) |
void |
writeObject(Object v) |
boolean |
writeOpt(int tag,
OptionalFormat format) |
boolean |
writeOptImpl(int tag,
OptionalFormat format) |
void |
writePendingObjects() |
void |
writeProxy(int tag,
ObjectPrx v) |
void |
writeProxy(int tag,
Optional<ObjectPrx> v) |
void |
writeProxy(ObjectPrx v) |
void |
writeSerializable(java.io.Serializable o) |
void |
writeShort(int tag,
short v) |
void |
writeShort(int tag,
ShortOptional v) |
void |
writeShort(short v) |
void |
writeShortBuffer(java.nio.ShortBuffer v) |
void |
writeShortSeq(int tag,
Optional<short[]> v) |
void |
writeShortSeq(int tag,
short[] v) |
void |
writeShortSeq(short[] v) |
void |
writeSize(int v) |
void |
writeString(int tag,
Optional<java.lang.String> v) |
void |
writeString(int tag,
java.lang.String v) |
void |
writeString(java.lang.String v) |
void |
writeStringSeq(int tag,
Optional<java.lang.String[]> v) |
void |
writeStringSeq(int tag,
java.lang.String[] v) |
void |
writeStringSeq(java.lang.String[] v) |
void |
writeUserException(UserException e) |
public BasicStream(Instance instance, EncodingVersion encoding)
public BasicStream(Instance instance, EncodingVersion encoding, boolean direct)
public BasicStream(Instance instance, EncodingVersion encoding, byte[] data)
public BasicStream(Instance instance, EncodingVersion encoding, java.nio.ByteBuffer data)
public void reset()
public void clear()
public Instance instance()
public java.lang.Object closure()
public java.lang.Object closure(java.lang.Object p)
public void swap(BasicStream other)
public void resetEncaps()
public void resize(int sz,
boolean reading)
public Buffer prepareWrite()
public Buffer getBuffer()
public void startWriteObject(SlicedData data)
public void endWriteObject()
public void startReadObject()
public SlicedData endReadObject(boolean preserve)
public void startWriteException(SlicedData data)
public void endWriteException()
public void startReadException()
public SlicedData endReadException(boolean preserve)
public void startWriteEncaps()
public void startWriteEncaps(EncodingVersion encoding, FormatType format)
public void endWriteEncaps()
public void endWriteEncapsChecked()
public void writeEmptyEncaps(EncodingVersion encoding)
public void writeEncaps(byte[] v)
public EncodingVersion getWriteEncoding()
public EncodingVersion startReadEncaps()
public void endReadEncaps()
public EncodingVersion skipEmptyEncaps()
public void endReadEncapsChecked()
public byte[] readEncaps(EncodingVersion encoding)
public EncodingVersion getReadEncoding()
public int getReadEncapsSize()
public EncodingVersion skipEncaps()
public void startWriteSlice(java.lang.String typeId,
int compactId,
boolean last)
public void endWriteSlice()
public java.lang.String startReadSlice()
public void endReadSlice()
public void skipSlice()
public void readPendingObjects()
public void writePendingObjects()
public void writeSize(int v)
public int readSize()
public int readAndCheckSeqSize(int minSize)
public int startSize()
public void endSize(int pos)
public void writeBlob(byte[] v)
public void writeBlob(byte[] v,
int off,
int len)
public byte[] readBlob(int sz)
public boolean writeOpt(int tag,
OptionalFormat format)
public boolean readOpt(int tag,
OptionalFormat expectedFormat)
public void writeByte(byte v)
public void writeByte(int tag,
ByteOptional v)
public void writeByte(int tag,
byte v)
public void rewriteByte(byte v,
int dest)
public void writeByteSeq(byte[] v)
public void writeByteSeq(int tag,
Optional<byte[]> v)
public void writeByteSeq(int tag,
byte[] v)
public void writeByteBuffer(java.nio.ByteBuffer v)
public void writeSerializable(java.io.Serializable o)
public byte readByte()
public void readByte(int tag,
ByteOptional v)
public byte[] readByteSeq()
public void readByteSeq(int tag,
Optional<byte[]> v)
public java.nio.ByteBuffer readByteBuffer()
public java.io.Serializable readSerializable()
public void writeBool(boolean v)
public void writeBool(int tag,
BooleanOptional v)
public void writeBool(int tag,
boolean v)
public void rewriteBool(boolean v,
int dest)
public void writeBoolSeq(boolean[] v)
public void writeBoolSeq(int tag,
Optional<boolean[]> v)
public void writeBoolSeq(int tag,
boolean[] v)
public boolean readBool()
public void readBool(int tag,
BooleanOptional v)
public boolean[] readBoolSeq()
public void readBoolSeq(int tag,
Optional<boolean[]> v)
public void writeShort(short v)
public void writeShort(int tag,
ShortOptional v)
public void writeShort(int tag,
short v)
public void writeShortSeq(short[] v)
public void writeShortSeq(int tag,
Optional<short[]> v)
public void writeShortSeq(int tag,
short[] v)
public void writeShortBuffer(java.nio.ShortBuffer v)
public short readShort()
public void readShort(int tag,
ShortOptional v)
public short[] readShortSeq()
public void readShortSeq(int tag,
Optional<short[]> v)
public java.nio.ShortBuffer readShortBuffer()
public void writeInt(int v)
public void writeInt(int tag,
IntOptional v)
public void writeInt(int tag,
int v)
public void rewriteInt(int v,
int dest)
public void writeIntSeq(int[] v)
public void writeIntSeq(int tag,
Optional<int[]> v)
public void writeIntSeq(int tag,
int[] v)
public void writeIntBuffer(java.nio.IntBuffer v)
public int readInt()
public void readInt(int tag,
IntOptional v)
public int[] readIntSeq()
public void readIntSeq(int tag,
Optional<int[]> v)
public java.nio.IntBuffer readIntBuffer()
public void writeLong(long v)
public void writeLong(int tag,
LongOptional v)
public void writeLong(int tag,
long v)
public void writeLongSeq(long[] v)
public void writeLongSeq(int tag,
Optional<long[]> v)
public void writeLongSeq(int tag,
long[] v)
public void writeLongBuffer(java.nio.LongBuffer v)
public long readLong()
public void readLong(int tag,
LongOptional v)
public long[] readLongSeq()
public void readLongSeq(int tag,
Optional<long[]> v)
public java.nio.LongBuffer readLongBuffer()
public void writeFloat(float v)
public void writeFloat(int tag,
FloatOptional v)
public void writeFloat(int tag,
float v)
public void writeFloatSeq(float[] v)
public void writeFloatSeq(int tag,
Optional<float[]> v)
public void writeFloatSeq(int tag,
float[] v)
public void writeFloatBuffer(java.nio.FloatBuffer v)
public float readFloat()
public void readFloat(int tag,
FloatOptional v)
public float[] readFloatSeq()
public void readFloatSeq(int tag,
Optional<float[]> v)
public java.nio.FloatBuffer readFloatBuffer()
public void writeDouble(double v)
public void writeDouble(int tag,
DoubleOptional v)
public void writeDouble(int tag,
double v)
public void writeDoubleSeq(double[] v)
public void writeDoubleSeq(int tag,
Optional<double[]> v)
public void writeDoubleSeq(int tag,
double[] v)
public void writeDoubleBuffer(java.nio.DoubleBuffer v)
public double readDouble()
public void readDouble(int tag,
DoubleOptional v)
public double[] readDoubleSeq()
public void readDoubleSeq(int tag,
Optional<double[]> v)
public java.nio.DoubleBuffer readDoubleBuffer()
public void writeString(java.lang.String v)
public void writeString(int tag,
Optional<java.lang.String> v)
public void writeString(int tag,
java.lang.String v)
public void writeStringSeq(java.lang.String[] v)
public void writeStringSeq(int tag,
Optional<java.lang.String[]> v)
public void writeStringSeq(int tag,
java.lang.String[] v)
public java.lang.String readString()
public void readString(int tag,
Optional<java.lang.String> v)
public java.lang.String[] readStringSeq()
public void readStringSeq(int tag,
Optional<java.lang.String[]> v)
public void writeProxy(ObjectPrx v)
public void writeProxy(int tag,
ObjectPrx v)
public ObjectPrx readProxy()
public void writeEnum(int v,
int maxValue)
public int readEnum(int maxValue)
public void writeObject(Object v)
public void writeObject(int tag,
Object v)
public void readObject(Patcher patcher)
public void writeUserException(UserException e)
public void throwException(UserExceptionFactory factory) throws UserException
UserExceptionpublic void sliceObjects(boolean b)
public boolean readOptImpl(int readTag,
OptionalFormat expectedFormat)
public boolean writeOptImpl(int tag,
OptionalFormat format)
public void skipOpt(OptionalFormat format)
public void skipOpts()
public void skip(int size)
public void skipSize()
public int pos()
public void pos(int n)
public int size()
public boolean isEmpty()
public BasicStream compress(int headerSize, int compressionLevel)
public BasicStream uncompress(int headerSize, int messageSizeMax)
public void expand(int n)
public static boolean compressible()