TPL 데이터 흐름에서 여러 대상 블록을 소스 블록과 어떻게 연결합니까?

Question

가 나는 두 출판사에서 출력을 생성하려면 다음을 기대하지만, 그것은 단지 첫 번째 출력 생성 : 나는 분명히 여기에 근본적인 뭔가를 누락

var broadcastBlock = new BroadcastBlock<int>(null); 
var transformBlock = new TransformBlock<int, int>(i => i*10); 
var publish1 = new ActionBlock<int>(i => Console.WriteLine("Publisher 1:" + i)); 
var publish2 = new ActionBlock<int>(i => Console.WriteLine("Publisher 2:" + i)); 

broadcastBlock.LinkTo(transformBlock, new DataflowLinkOptions() { PropagateCompletion = true }); 
transformBlock.LinkTo(publish1, new DataflowLinkOptions() { PropagateCompletion = true }); 
transformBlock.LinkTo(publish2, new DataflowLinkOptions() { PropagateCompletion = true }); 

foreach (var i in Enumerable.Range(0, 5)) 
{ 
    broadcastBlock.Post(i); 
} 
broadcastBlock.Complete(); 
Task.WhenAll(publish1.Completion, publish2.Completion).Wait(); 

, 어떤 아이디어?

Answer 1

TransformBlock에 2 ActionBlock을 연결하고 있습니다. 2 ActionBlock을 BrodcastBlock에 연결하고 BroadcastBlock을 TransformBlock에 연결해야합니다.

당신이 무엇 :

BroadCast => Transfrom => ActionBlock 
         => ActionBlock 

당신이 필요로하는 무엇을 : 답장을

Transfrom => BroadCast => ActionBlock 
         => ActionBlock