如何批量处理 IAsyncEnumerable<T>，在连续批次之间强制执行最大间隔策略？
我有一个异步消息序列（流），这些消息有时大量到达...