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)
534internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 770Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 804int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 822_dataflowBlockOptions.MaxMessagesPerTask == DataflowBlockOptions.Unbounded ? 884return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || 963else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 965_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 1014internal DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }