Add FUTURE

rabbitmq · Mar 3, 2023 · 638369b · 638369b
1 parent fbd0f81
commit 638369b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/RabbitMQ.Stream.Client/Connection.cs b/RabbitMQ.Stream.Client/Connection.cs
@@ -164,6 +164,11 @@ private async ValueTask<bool> AwaitFlushAndRelease(ValueTask<FlushResult> task)
 
         private int WriteCommandPayloadSize<T>(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);