Defines a Decoder that handles translating the encoded AMQP performative bytes into the appropriate Proton AMQP types. More...

Inheritance diagram for Apache.Qpid.Proton.Codec.IStreamDecoder:

Public Member Functions
IStreamDecoderState	NewDecoderState ()
	Creates and returns a new decoder state object that should be used when decoding values with the decoder instance.

bool?	ReadBoolean (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

bool	ReadBoolean (Stream stream, IStreamDecoderState state, bool defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

sbyte?	ReadByte (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

sbyte	ReadByte (Stream stream, IStreamDecoderState state, sbyte defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

byte?	ReadUnsignedByte (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

byte	ReadUnsignedByte (Stream stream, IStreamDecoderState state, byte defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

char?	ReadCharacter (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

char	ReadCharacter (Stream stream, IStreamDecoderState state, char defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Decimal32	ReadDecimal32 (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Decimal64	ReadDecimal64 (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Decimal128	ReadDecimal128 (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

short?	ReadShort (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

short	ReadShort (Stream stream, IStreamDecoderState state, short defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

ushort?	ReadUnsignedShort (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

ushort	ReadUnsignedShort (Stream stream, IStreamDecoderState state, ushort defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

int?	ReadInt (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

int	ReadInt (Stream stream, IStreamDecoderState state, int defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

uint?	ReadUnsignedInteger (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

uint	ReadUnsignedInteger (Stream stream, IStreamDecoderState state, uint defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

long?	ReadLong (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

long	ReadLong (Stream stream, IStreamDecoderState state, long defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

ulong?	ReadUnsignedLong (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

ulong	ReadUnsignedLong (Stream stream, IStreamDecoderState state, ulong defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

float?	ReadFloat (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

float	ReadFloat (Stream stream, IStreamDecoderState state, float defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

double?	ReadDouble (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

double	ReadDouble (Stream stream, IStreamDecoderState state, double defaultValue)
	Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

IProtonBuffer	ReadBinary (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

string	ReadString (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Symbol	ReadSymbol (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

string	ReadSymbolAsString (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

ulong?	ReadTimestamp (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Guid?	ReadGuid (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

object	ReadObject (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

T	ReadObject< T > (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

T[]	ReadMultiple< T > (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

IDictionary< K, V >	ReadMap< K, V > (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

IList< V >	ReadList< V > (Stream stream, IStreamDecoderState state)
	Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

IDeliveryTag	ReadDeliveryTag (Stream stream, IStreamDecoderState state)
	This method expects to read a Binary encoded type from the provided stream and constructs a IDeliveryTag type that wraps the bytes encoded. If the encoding is NULL AMQP type then this method returns null.

IStreamTypeDecoder	ReadNextTypeDecoder (Stream stream, IStreamDecoderState state)
	Reads from the given IProtonstream instance and returns a ITypeDecoder that can read the next encoded AMQP type from the byte stream. If an error occurs while attempting to read the encoded type a DecodeException is thrown.

IStreamTypeDecoder	PeekNextTypeDecoder (Stream stream, IStreamDecoderState state)
	Peeks ahead in the given IProtonstream instance and returns a ITypeDecoder that can read the next encoded AMQP type from the byte stream. If an error occurs while attempting to read the encoded type a DecodeException is thrown. The underlying stream state is not modified as a result of calling the peek ahead operation and the returned decoder will not correctly be able to read the encoded type until the type encoding bytes are read.

IStreamDecoder	RegisterDescribedTypeDecoder (IStreamDescribedTypeDecoder decoder)
	Allows for a custom described type decoder to be registered with this decoder instance for use when decoding AMQP described types from incoming byte streams.

Properties
IStreamDecoderState	CachedDecoderState `[get]`
	Returns a cached decoder state instance that can be used be single threaded readers that use this decoder instance.

Detailed Description

Defines a Decoder that handles translating the encoded AMQP performative bytes into the appropriate Proton AMQP types.

Member Function Documentation

◆ NewDecoderState()

IStreamDecoderState Apache.Qpid.Proton.Codec.IStreamDecoder.NewDecoderState ( )

Creates and returns a new decoder state object that should be used when decoding values with the decoder instance.

Returns

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ PeekNextTypeDecoder()

IStreamTypeDecoder Apache.Qpid.Proton.Codec.IStreamDecoder.PeekNextTypeDecoder	(	Stream	stream,
		IStreamDecoderState	state
	)

Peeks ahead in the given IProtonstream instance and returns a ITypeDecoder that can read the next encoded AMQP type from the byte stream. If an error occurs while attempting to read the encoded type a DecodeException is thrown. The underlying stream state is not modified as a result of calling the peek ahead operation and the returned decoder will not correctly be able to read the encoded type until the type encoding bytes are read.

Template Parameters

T	The type that the decoder handles

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadBinary()

IProtonBuffer Apache.Qpid.Proton.Codec.IStreamDecoder.ReadBinary	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadBoolean() [1/2]

bool? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadBoolean	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadBoolean() [2/2]

bool Apache.Qpid.Proton.Codec.IStreamDecoder.ReadBoolean	(	Stream	stream,
		IStreamDecoderState	state,
		bool	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadByte() [1/2]

sbyte? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadByte	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadByte() [2/2]

sbyte Apache.Qpid.Proton.Codec.IStreamDecoder.ReadByte	(	Stream	stream,
		IStreamDecoderState	state,
		sbyte	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadCharacter() [1/2]

char? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadCharacter	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadCharacter() [2/2]

char Apache.Qpid.Proton.Codec.IStreamDecoder.ReadCharacter	(	Stream	stream,
		IStreamDecoderState	state,
		char	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDecimal128()

Decimal128 Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDecimal128	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDecimal32()

Decimal32 Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDecimal32	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDecimal64()

Decimal64 Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDecimal64	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDeliveryTag()

IDeliveryTag Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDeliveryTag	(	Stream	stream,
		IStreamDecoderState	state
	)

This method expects to read a Binary encoded type from the provided stream and constructs a IDeliveryTag type that wraps the bytes encoded. If the encoding is NULL AMQP type then this method returns null.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDouble() [1/2]

double? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDouble	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadDouble() [2/2]

double Apache.Qpid.Proton.Codec.IStreamDecoder.ReadDouble	(	Stream	stream,
		IStreamDecoderState	state,
		double	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadFloat() [1/2]

float? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadFloat	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadFloat() [2/2]

float Apache.Qpid.Proton.Codec.IStreamDecoder.ReadFloat	(	Stream	stream,
		IStreamDecoderState	state,
		float	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadGuid()

Guid? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadGuid	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadInt() [1/2]

int? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadInt	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadInt() [2/2]

int Apache.Qpid.Proton.Codec.IStreamDecoder.ReadInt	(	Stream	stream,
		IStreamDecoderState	state,
		int	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadList< V >()

IList< V > Apache.Qpid.Proton.Codec.IStreamDecoder.ReadList< V >	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

◆ ReadLong() [1/2]

long? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadLong	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadLong() [2/2]

long Apache.Qpid.Proton.Codec.IStreamDecoder.ReadLong	(	Stream	stream,
		IStreamDecoderState	state,
		long	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadMap< K, V >()

IDictionary< K, V > Apache.Qpid.Proton.Codec.IStreamDecoder.ReadMap< K, V >	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadMultiple< T >()

T[] Apache.Qpid.Proton.Codec.IStreamDecoder.ReadMultiple< T >	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadNextTypeDecoder()

IStreamTypeDecoder Apache.Qpid.Proton.Codec.IStreamDecoder.ReadNextTypeDecoder	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads from the given IProtonstream instance and returns a ITypeDecoder that can read the next encoded AMQP type from the byte stream. If an error occurs while attempting to read the encoded type a DecodeException is thrown.

Template Parameters

T	The type that the decoder handles

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadObject()

object Apache.Qpid.Proton.Codec.IStreamDecoder.ReadObject	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadObject< T >()

T Apache.Qpid.Proton.Codec.IStreamDecoder.ReadObject< T >	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadShort() [1/2]

short? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadShort	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadShort() [2/2]

short Apache.Qpid.Proton.Codec.IStreamDecoder.ReadShort	(	Stream	stream,
		IStreamDecoderState	state,
		short	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadString()

string Apache.Qpid.Proton.Codec.IStreamDecoder.ReadString	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadSymbol()

Symbol Apache.Qpid.Proton.Codec.IStreamDecoder.ReadSymbol	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadSymbolAsString()

string Apache.Qpid.Proton.Codec.IStreamDecoder.ReadSymbolAsString	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadTimestamp()

ulong? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadTimestamp	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedByte() [1/2]

byte? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedByte	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedByte() [2/2]

byte Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedByte	(	Stream	stream,
		IStreamDecoderState	state,
		byte	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedInteger() [1/2]

uint? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedInteger	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedInteger() [2/2]

uint Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedInteger	(	Stream	stream,
		IStreamDecoderState	state,
		uint	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedLong() [1/2]

ulong? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedLong	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedLong() [2/2]

ulong Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedLong	(	Stream	stream,
		IStreamDecoderState	state,
		ulong	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedShort() [1/2]

ushort? Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedShort	(	Stream	stream,
		IStreamDecoderState	state
	)

Reads the encoded value from the given byte stream and returns it. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ ReadUnsignedShort() [2/2]

ushort Apache.Qpid.Proton.Codec.IStreamDecoder.ReadUnsignedShort	(	Stream	stream,
		IStreamDecoderState	state,
		ushort	defaultValue
	)

Reads the encoded value from the given byte stream and returns it or the default if the encoding type is null. If the next value in the byte stream is not of the requested type an error is thrown. If the caller wishes to recover from errors due to unexpected types the byte stream should be marked and reset in order to make additional read attempts.

Parameters

stream	The stream to read the encoded value from
state	A decoder state instance to use when decoding
defaultValue	The default value to return for null encodings

Returns: The decoded object or null if the encoding was null.

Exceptions

DecodeException If an error occurs during the decode operation

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

◆ RegisterDescribedTypeDecoder()

IStreamDecoder Apache.Qpid.Proton.Codec.IStreamDecoder.RegisterDescribedTypeDecoder ( IStreamDescribedTypeDecoder decoder )

Allows for a custom described type decoder to be registered with this decoder instance for use when decoding AMQP described types from incoming byte streams.

Parameters

decoder A described type decoder to register

Returns: This IDecoder instance.

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

Property Documentation

◆ CachedDecoderState

IStreamDecoderState Apache.Qpid.Proton.Codec.IStreamDecoder.CachedDecoderState

get

Returns a cached decoder state instance that can be used be single threaded readers that use this decoder instance.

Returns: A cached decoder state object that can be used by single threaded readerss

Implemented in Apache.Qpid.Proton.Codec.Decoders.ProtonStreamDecoder.

The documentation for this interface was generated from the following file:

src/Proton/Codec/IStreamDecoder.cs

Public Member Functions

Properties

Detailed Description

Member Function Documentation

◆ NewDecoderState()

◆ PeekNextTypeDecoder()

◆ ReadBinary()

◆ ReadBoolean() [1/2]

◆ ReadBoolean() [2/2]

◆ ReadByte() [1/2]

◆ ReadByte() [2/2]

◆ ReadCharacter() [1/2]

◆ ReadCharacter() [2/2]

◆ ReadDecimal128()

◆ ReadDecimal32()

◆ ReadDecimal64()

◆ ReadDeliveryTag()

◆ ReadDouble() [1/2]

◆ ReadDouble() [2/2]

◆ ReadFloat() [1/2]

◆ ReadFloat() [2/2]

◆ ReadGuid()

◆ ReadInt() [1/2]

◆ ReadInt() [2/2]

◆ ReadList< V >()

◆ ReadLong() [1/2]

◆ ReadLong() [2/2]

◆ ReadMap< K, V >()

◆ ReadMultiple< T >()

◆ ReadNextTypeDecoder()

◆ ReadObject()

◆ ReadObject< T >()

◆ ReadShort() [1/2]

◆ ReadShort() [2/2]

◆ ReadString()

◆ ReadSymbol()

◆ ReadSymbolAsString()

◆ ReadTimestamp()

◆ ReadUnsignedByte() [1/2]

◆ ReadUnsignedByte() [2/2]

◆ ReadUnsignedInteger() [1/2]

◆ ReadUnsignedInteger() [2/2]

◆ ReadUnsignedLong() [1/2]

◆ ReadUnsignedLong() [2/2]

◆ ReadUnsignedShort() [1/2]

◆ ReadUnsignedShort() [2/2]

◆ RegisterDescribedTypeDecoder()

Property Documentation

◆ CachedDecoderState