org.infinispan.protostream.impl

Class ProtoStreamReaderImpl

java.lang.Object

org.infinispan.protostream.impl.ProtoStreamReaderImpl

All Implemented Interfaces:

MessageMarshaller.ProtoStreamReader

public final class ProtoStreamReaderImpl
extends Object
implements MessageMarshaller.ProtoStreamReader

Author:

anistor@redhat.com

Constructor Summary

Constructors

Constructor and Description
ProtoStreamReaderImpl(SerializationContext ctx)

Method Summary

Modifier and Type	Method and Description
<A> A	read(com.google.protobuf.CodedInputStream in, Class<A> clazz)
<A> A	read(com.google.protobuf.CodedInputStream in, MessageMarshaller<A> marshaller)
<A> A[]	readArray(String fieldName, Class<? extends A> clazz)
Boolean	readBoolean(String fieldName)
byte[]	readBytes(String fieldName)
<A,C extends Collection<? super A>> C	readCollection(String fieldName, C collection, Class<? extends A> clazz)
Double	readDouble(String fieldName)
Float	readFloat(String fieldName)
Integer	readInt(String fieldName) Can't return an int here because the field might be declared optional and missing so we might need to return a null.
Long	readLong(String fieldName)
<A> A	readObject(String fieldName, Class<? extends A> clazz)
String	readString(String fieldName)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtoStreamReaderImpl

public ProtoStreamReaderImpl(SerializationContext ctx)

Method Detail

read

public <A> A read(com.google.protobuf.CodedInputStream in,
                  Class<A> clazz)
           throws IOException

Throws:

IOException

read

public <A> A read(com.google.protobuf.CodedInputStream in,
                  MessageMarshaller<A> marshaller)
           throws IOException

Throws:

IOException

readInt

public Integer readInt(String fieldName)
                throws IOException

Description copied from interface: MessageMarshaller.ProtoStreamReader

Can't return an int here because the field might be declared optional and missing so we might need to return a null.

Specified by:

readInt in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readLong

public Long readLong(String fieldName)
              throws IOException

Specified by:

readLong in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readFloat

public Float readFloat(String fieldName)
                throws IOException

Specified by:

readFloat in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readDouble

public Double readDouble(String fieldName)
                  throws IOException

Specified by:

readDouble in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBoolean

public Boolean readBoolean(String fieldName)
                    throws IOException

Specified by:

readBoolean in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readString

public String readString(String fieldName)
                  throws IOException

Specified by:

readString in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBytes

public byte[] readBytes(String fieldName)
                 throws IOException

Specified by:

readBytes in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readObject

public <A> A readObject(String fieldName,
                        Class<? extends A> clazz)
                 throws IOException

Specified by:

readObject in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readCollection

public <A,C extends Collection<? super A>> C readCollection(String fieldName,
                                                            C collection,
                                                            Class<? extends A> clazz)
                                                     throws IOException

Specified by:

readCollection in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readArray

public <A> A[] readArray(String fieldName,
                         Class<? extends A> clazz)
                  throws IOException

Specified by:

readArray in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException