1 write to Target
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2378
Target
= new ActionBlock<TOutput>((Func<TOutput, Task>)ProcessItemAsync, DataflowBlock._nonGreedyExecutionOptions);
6 references to Target
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (6)
2235
_observersState.
Target
.Completion.IsCompleted)
2247
_observersState.Unlinker = _source.LinkTo(_observersState.
Target
);
2382
Target
.Completion.ContinueWith(
2394
ti.
Target
.Complete();
2395
ti.
Target
.Completion.ContinueWith(
2468
Debug.Assert(
Target
.Completion.IsCompleted, "The target must have already completed in order to notify of completion.");