DataflowEx가 완료되지 않음

Question

오픈 소스 라이브러리 DataflowEx을 다음 Dataflow 선언과 함께 사용하려고합니다. AAAA 18 | 54.3773 : 32 : 32 : 나는

var requestClientFlow = new RequestClientFlow(this); 
requestClientFlow.Post(""); 
requestClientFlow.Complete(); 
await requestClientFlow.InputBlock.Completion; 

이 완료 내 출력 표시

(18)처럼 소비

class RequestClientFlow :Dataflow<string>{ 
    private readonly ILogger _logger; 
    private readonly Dataflow<string, WebProxy> _webproxyDataflow; 
    private readonly Dataflow<WebProxy, HttpClient> _httpClientDataflow; 

    public RequestClientFlow(ILogger logger) : this(DataflowOptions.Default){ 
     _logger = logger; 
    } 

    public Dataflow<WebProxy, HttpClient> HttpClientDataflow => _httpClientDataflow; 

    public RequestClientFlow(DataflowOptions dataflowOptions) : base(dataflowOptions){ 
     _webproxyDataflow = new TransformBlock<string,WebProxy>(s => { 
      _logger.WriteLine("aaaa"); 
      return new WebProxy(); 
     }).ToDataflow(); 
     _httpClientDataflow = new TransformBlock<WebProxy,HttpClient>(proxy => { 
      _logger.WriteLine("bbbb"); 
      return new HttpClient(); 
     }).ToDataflow(); 
     _webproxyDataflow.LinkTo(_httpClientDataflow); 
     RegisterChild(_webproxyDataflow); 
     RegisterChild(_httpClientDataflow); 
    } 

    public override ITargetBlock<string> InputBlock => _webproxyDataflow.InputBlock; 
} 

54.3773 | BBBB

1 통과, 0 실패, 0 생략, 1.45 초 (xUnit.net 2.3.1 빌드 3858).

그러나 이해의 나

내가 또한

requestClientFlow.Complete(); 
    await requestClientFlow.CompletionTask; 

하거나 완료되지도

await requestClientFlow.SignalAndWaitForCompletionAsync(); 

을 사용할 수 있어야 프레임 워크 문서에서입니다. 누군가 내가 내가 뭘 잘못했는지 이해하도록 도와 줄 수 있습니까?

Answer 1

마지막 블록이 TransformBlock이므로 흐름을 완료 할 수 없습니다. 첫 번째 예에서는 await입력 완료 블록이 실제로 완료됩니다. 출력 블록은 출력 버퍼의 항목이 갈 곳이 없어 완료 할 수 없습니다. DataflowEx 라이브러리는 흐름의 마지막 블록에 올바르게 awaiting입니다. 완성을 위해 ActionBlock 또는 NullTarget을 끝에 추가 할 수 있습니다. DataflowEx의 측면에서

최종 흐름은

public interface IDataflow<in TIn> : IDataflow 
{ 
    ITargetBlock<TIn> InputBlock { get; } 
} 

을 implmeneting되어야 라이브러리 쇼에 대한 github 페이지의 예로서 :

public class AggregatorFlow : Dataflow<string> 
{ 
    //...// 

    public AggregatorFlow() : base(DataflowOptions.Default) 
    { 
     _splitter = new TransformBlock<string, KeyValuePair<string, int>>(s => this.Split(s)); 
     _dict = new Dictionary<string, int>(); 

     //***Note The ActionBlock here*** 
     _aggregater = new ActionBlock<KeyValuePair<string, int>>(p => this.Aggregate(p)); 

     //Block linking 
     _splitter.LinkTo(_aggregater, new DataflowLinkOptions() { PropagateCompletion = true }); 

     /* IMPORTANT */ 
     RegisterChild(_splitter); 
     RegisterChild(_aggregater); 
    } 

    //...// 
}