Есть ли блок потока данных TPL, который не принимает ввода, а возвращает выход?

Question

В названии моего вопроса говорится все.

Я ищу блок потока данных TPL, который не требует ввода.

Прямо сейчас я использую блок преобразования, но его ввод не используется.

Answer 1

Я бы построил такой блок из BufferBlock<T>: метод принимает делегат, который представляет сторону блока ITargetBlock<T> и возвращает его сторону ISourceBlock<T>. Таким образом, делегат может отправлять входные данные блоку, но извне он выглядит как блок, который только производит вывод.

Код:

public static ISourceBlock<T> CreateProducerBlock<T>(
    Func<ITargetBlock<T>, Task> producer, 
    int boundedCapacity = DataflowBlockOptions.Unbounded) 
{ 
    var block = new BufferBlock<T>(
     new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity }); 

    Task.Run(async() => 
    { 
     try 
     { 
      await producer(block); 

      block.Complete(); 
     } 
     catch (Exception ex) 
     { 
      ((IDataflowBlock)block).Fault(ex); 
     } 
    }); 

    return block; 
} 

Пример использования:

var producer = CreateProducerBlock<int>(async target => 
{ 
    await target.SendAsync(10); 
    await target.SendAsync(20); 
}); 

ITargetBlock<int> consumer = …; 

producer.LinkTo(consumer);