in src/Framing/Source.cs [128:184]
protected override void OnDecode(ByteBuffer buffer, int count)
{
if (count-- > 0)
{
this.Address = Address.Decode(buffer);
}
if (count-- > 0)
{
this.Durable = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.ExpiryPolicy = AmqpCodec.DecodeSymbol(buffer);
}
if (count-- > 0)
{
this.Timeout = AmqpCodec.DecodeUInt(buffer);
}
if (count-- > 0)
{
this.Dynamic = AmqpCodec.DecodeBoolean(buffer);
}
if (count-- > 0)
{
this.DynamicNodeProperties = AmqpCodec.DecodeMap<Fields>(buffer);
}
if (count-- > 0)
{
this.DistributionMode = AmqpCodec.DecodeSymbol(buffer);
}
if (count-- > 0)
{
this.FilterSet = AmqpCodec.DecodeMap<FilterSet>(buffer);
}
if (count-- > 0)
{
this.DefaultOutcome = (Outcome)AmqpCodec.DecodeAmqpDescribed(buffer);
}
if (count-- > 0)
{
this.Outcomes = AmqpCodec.DecodeMultiple<AmqpSymbol>(buffer);
}
if (count-- > 0)
{
this.Capabilities = AmqpCodec.DecodeMultiple<AmqpSymbol>(buffer);
}
}