Package org.infinispan.protostream.impl

Class TagWriterImpl.OutputStreamEncoder

java.lang.Object

org.infinispan.protostream.impl.TagWriterImpl.Encoder

org.infinispan.protostream.impl.TagWriterImpl.OutputStreamEncoder

Enclosing class:

TagWriterImpl

private static final class TagWriterImpl.OutputStreamEncoder
extends TagWriterImpl.Encoder

Writes to an OutputStream and performs internal buffering to minimize the number of stream writes.

Field Summary

Fields

Modifier and Type	Field	Description
private final TagWriterImpl.ByteArrayEncoder	buffer
private final OutputStream	out

Constructor Summary

Constructors

Constructor	Description
OutputStreamEncoder(OutputStream out, int bufferSize)

Method Summary

Modifier and Type	Method	Description
(package private) void	flush()	Commits the witten bytes after several write operations were performed.
(package private) void	writeBoolField(int fieldNumber, boolean value)
(package private) void	writeByte(byte value)
(package private) void	writeBytes(byte[] value, int offset, int length)
(package private) void	writeBytes(ByteBuffer value)
(package private) void	writeFixed32(int value)
(package private) void	writeFixed32Field(int fieldNumber, int value)
(package private) void	writeFixed64(long value)
(package private) void	writeFixed64Field(int fieldNumber, long value)
(package private) void	writeLengthDelimitedField(int fieldNumber, int length)
(package private) void	writeUInt32Field(int fieldNumber, int value)
(package private) void	writeUInt64Field(int fieldNumber, long value)
(package private) void	writeVarint32(int value)
(package private) void	writeVarint64(long value)

Methods inherited from class java.lang.Object

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

Field Details

buffer

private final TagWriterImpl.ByteArrayEncoder buffer

out

private final OutputStream out

Constructor Details

OutputStreamEncoder

OutputStreamEncoder(OutputStream out,
 int bufferSize)

Method Details

writeUInt32Field

void writeUInt32Field(int fieldNumber,
 int value)
               throws IOException

Overrides:

writeUInt32Field in class TagWriterImpl.Encoder

Throws:

IOException

writeUInt64Field

void writeUInt64Field(int fieldNumber,
 long value)
               throws IOException

Overrides:

writeUInt64Field in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed32Field

void writeFixed32Field(int fieldNumber,
 int value)
                throws IOException

Overrides:

writeFixed32Field in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed64Field

void writeFixed64Field(int fieldNumber,
 long value)
                throws IOException

Overrides:

writeFixed64Field in class TagWriterImpl.Encoder

Throws:

IOException

writeBoolField

void writeBoolField(int fieldNumber,
 boolean value)
             throws IOException

Overrides:

writeBoolField in class TagWriterImpl.Encoder

Throws:

IOException

writeLengthDelimitedField

void writeLengthDelimitedField(int fieldNumber,
 int length)
                        throws IOException

Overrides:

writeLengthDelimitedField in class TagWriterImpl.Encoder

Throws:

IOException

writeVarint32

void writeVarint32(int value)
            throws IOException

Specified by:

writeVarint32 in class TagWriterImpl.Encoder

Throws:

IOException

writeVarint64

void writeVarint64(long value)
            throws IOException

Specified by:

writeVarint64 in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed32

void writeFixed32(int value)
           throws IOException

Specified by:

writeFixed32 in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed64

void writeFixed64(long value)
           throws IOException

Specified by:

writeFixed64 in class TagWriterImpl.Encoder

Throws:

IOException

writeByte

void writeByte(byte value)
        throws IOException

Specified by:

writeByte in class TagWriterImpl.Encoder

Throws:

IOException

writeBytes

void writeBytes(byte[] value,
 int offset,
 int length)
         throws IOException

Specified by:

writeBytes in class TagWriterImpl.Encoder

Throws:

IOException

writeBytes

void writeBytes(ByteBuffer value)
         throws IOException

Specified by:

writeBytes in class TagWriterImpl.Encoder

Throws:

IOException

flush

void flush()
    throws IOException

Description copied from class: TagWriterImpl.Encoder

Commits the witten bytes after several write operations were performed. Updates counters, positions, whatever.

Overrides:

flush in class TagWriterImpl.Encoder

Throws:

IOException