From 638369bdb4c21662d9b944e75c482484e3085f34 Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Fri, 3 Mar 2023 07:16:23 -0800 Subject: [PATCH] Add FUTURE --- RabbitMQ.Stream.Client/Connection.cs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/RabbitMQ.Stream.Client/Connection.cs b/RabbitMQ.Stream.Client/Connection.cs index 2610ac18..7f18e8b4 100644 --- a/RabbitMQ.Stream.Client/Connection.cs +++ b/RabbitMQ.Stream.Client/Connection.cs @@ -164,6 +164,11 @@ private async ValueTask AwaitFlushAndRelease(ValueTask task) private int WriteCommandPayloadSize(T command) where T : struct, ICommand { + /* + * TODO FUTURE + * This code could be moved into a common base class for all outgoing + * commands + */ var payloadSize = command.SizeNeeded; var mem = writer.GetSpan(WireFormatting.SizeofUInt32); var written = WireFormatting.WriteUInt32(mem, (uint)payloadSize);