1 write to Target
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2465
Target
= new ActionBlock<TOutput>((Func<TOutput, Task>)ProcessItemAsync, DataflowBlock._nonGreedyExecutionOptions);
6 references to Target
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (6)
2322
_observersState.
Target
.Completion.IsCompleted)
2334
_observersState.Unlinker = _source.LinkTo(_observersState.
Target
);
2469
Target
.Completion.ContinueWith(
2481
ti.
Target
.Complete();
2482
ti.
Target
.Completion.ContinueWith(
2555
Debug.Assert(
Target
.Completion.IsCompleted, "The target must have already completed in order to notify of completion.");