in src/Types/Encoder.cs [855:904]
public static void WriteArray(ByteBuffer buffer, Array value)
{
if (value == null)
{
AmqpBitConverter.WriteUByte(buffer, FormatCode.Null);
}
else
{
int count = value.Length;
Fx.Assert(count > 0, "must have at least 1 element in array");
int pos = buffer.WritePos;
AmqpBitConverter.WriteUByte(buffer, 0);
AmqpBitConverter.WriteUInt(buffer, 0);
AmqpBitConverter.WriteUInt(buffer, 0);
for (int i = 0; i < count; ++i)
{
object item = value.GetValue(i);
if (i == 0)
{
Encoder.WriteObject(buffer, item, false);
}
else
{
int lastPos = buffer.WritePos - 1;
byte lastByte = buffer.Buffer[lastPos];
buffer.Shrink(1);
Encoder.WriteObject(buffer, item, false);
buffer.Buffer[lastPos] = lastByte;
}
}
int size = buffer.WritePos - pos - 9;
if (size < byte.MaxValue && count <= byte.MaxValue)
{
buffer.Buffer[pos] = FormatCode.Array8;
buffer.Buffer[pos + 1] = (byte)(size + 1);
buffer.Buffer[pos + 2] = (byte)count;
Array.Copy(buffer.Buffer, pos + 9, buffer.Buffer, pos + 3, size);
buffer.Shrink(6);
}
else
{
buffer.Buffer[pos] = FormatCode.Array32;
AmqpBitConverter.WriteInt(buffer.Buffer, pos + 1, size + 4);
AmqpBitConverter.WriteInt(buffer.Buffer, pos + 5, count);
}
}
}