in foreign/csharp/Iggy_SDK/MessagesDispatcher/MessageSenderDispatcher.cs [100:116]
private static bool CanBatchMessages(ReadOnlySpan<MessageSendRequest> requests)
{
for (int i = 0; i < requests.Length - 1; i++)
{
var start = requests[i];
var next = requests[i + 1];
if (!start.StreamId.Equals(next.StreamId)
|| !start.TopicId.Equals(next.TopicId)
|| start.Partitioning.Kind is not Partitioning.PartitionId
|| !start.Partitioning.Value.SequenceEqual(next.Partitioning.Value))
{
return false;
}
}
return true;
}