1 write to Target
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2380
Target
= new ActionBlock<TOutput>((Func<TOutput, Task>)ProcessItemAsync, DataflowBlock._nonGreedyExecutionOptions);
6 references to Target
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (6)
2237
_observersState.
Target
.Completion.IsCompleted)
2249
_observersState.Unlinker = _source.LinkTo(_observersState.
Target
);
2384
Target
.Completion.ContinueWith(
2396
ti.
Target
.Complete();
2397
ti.
Target
.Completion.ContinueWith(
2470
Debug.Assert(
Target
.Completion.IsCompleted, "The target must have already completed in order to notify of completion.");