1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Internal\SourceCore.cs (1)
114_dataflowBlockOptions = dataflowBlockOptions;
8 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (8)
Internal\SourceCore.cs (8)
528internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 764Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 798int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 816_dataflowBlockOptions.MaxMessagesPerTask == DataflowBlockOptions.Unbounded ? 878return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || 957else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 959_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 1008internal DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }