如何在TPL数据流中重置延迟/拒绝的消息

// 创建 TransformBlock
var transformBlock = new TransformBlock<Message, Message>(async message =>
{
    // 处理消息的转换和重置延迟/拒绝的逻辑
    if (message.NeedResetDelay)
    {
        // 将需要重置延迟/拒绝的消息发送到 BufferBlock
        await bufferBlock.SendAsync(message);
        return null; // 返回 null 表示消息已被处理
    }
    
    // 其他处理逻辑
    // ...
    
    return message; // 返回处理后的消息
});

// 创建 BufferBlock
var bufferBlock = new BufferBlock<Message>();

// 设置定时器，定时将消息重新发送到 TransformBlock 进行处理
var timer = new Timer(async state =>
{
    var messages = new List<Message>();
    
    // 从 BufferBlock 中获取需要重置延迟/拒绝的消息
    while (bufferBlock.TryReceive(out var message))
    {
        messages.Add(message);
    }
    
    // 将消息重新发送到 TransformBlock 进行处理
    foreach (var message in messages)
    {
        await transformBlock.SendAsync(message);
    }
}, null, TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(5));