in src/Framing/Begin.cs [125:166]
protected override void OnDecode(ByteBuffer buffer, int count)
{
if (count-- > 0)
{
this.RemoteChannel = AmqpCodec.DecodeUShort(buffer);
}
if (count-- > 0)
{
this.NextOutgoingId = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.IncomingWindow = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.OutgoingWindow = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.HandleMax = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.OfferedCapabilities = AmqpCodec.DecodeMultiple<AmqpSymbol>(buffer);
}
if (count-- > 0)
{
this.DesiredCapabilities = AmqpCodec.DecodeMultiple<AmqpSymbol>(buffer);
}
if (count-- > 0)
{
this.Properties = AmqpCodec.DecodeMap<Fields>(buffer);
}
}