2 types derived from DataflowBlockOptions
System.Threading.Tasks.Dataflow (2)
Base\DataflowBlockOptions.cs (2)
250public class ExecutionDataflowBlockOptions : DataflowBlockOptions 382public class GroupingDataflowBlockOptions : DataflowBlockOptions
2 instantiations of DataflowBlockOptions
System.Threading.Tasks.Dataflow (2)
Base\DataflowBlockOptions.cs (2)
85internal static readonly DataflowBlockOptions Default = new DataflowBlockOptions(); 93new DataflowBlockOptions
47 references to DataflowBlockOptions
System.Threading.Tasks.Dataflow (47)
Base\DataflowBlock.cs (6)
1711return Choose(source1, action1, source2, action2, DataflowBlockOptions.Default); 1747DataflowBlockOptions dataflowBlockOptions) 1811return Choose(source1, action1, source2, action2, source3, action3, DataflowBlockOptions.Default); 1852DataflowBlockOptions dataflowBlockOptions) 1904DataflowBlockOptions dataflowBlockOptions) 1989DataflowBlockOptions dataflowBlockOptions)
Base\DataflowBlockOptions.cs (10)
23/// <see cref="DataflowBlockOptions"/> is mutable and can be configured through its properties. 56/// to the provided <see cref="DataflowBlockOptions"/> instance should not affect the behavior 63/// A constant used to specify an unlimited quantity for <see cref="DataflowBlockOptions"/> members 81/// <summary>A default instance of <see cref="DataflowBlockOptions"/>.</summary> 85internal static readonly DataflowBlockOptions Default = new DataflowBlockOptions(); 87/// <summary>Returns this <see cref="DataflowBlockOptions"/> instance if it's the default instance or else a cloned instance.</summary> 89internal DataflowBlockOptions DefaultOrClone() 104/// <summary>Initializes the <see cref="DataflowBlockOptions"/>.</summary> 252/// <summary>A default instance of <see cref="DataflowBlockOptions"/>.</summary> 384/// <summary>A default instance of <see cref="DataflowBlockOptions"/>.</summary>
Base\DataflowLinkOptions.cs (1)
53internal const int Unbounded = DataflowBlockOptions.Unbounded;
Blocks\ActionBlock.cs (1)
90dataflowBlockOptions.BoundedCapacity == DataflowBlockOptions.Unbounded)
Blocks\BatchedJoinBlock.cs (2)
60if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) throw new ArgumentException(SR.Argument_BoundedCapacityNotSupported, nameof(dataflowBlockOptions)); 308dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded)
Blocks\BroadcastBlock.cs (8)
55this(cloningFunction, DataflowBlockOptions.Default) 58/// <summary>Initializes the <see cref="BroadcastBlock{T}"/> with the specified cloning function and <see cref="DataflowBlockOptions"/>.</summary> 65public BroadcastBlock(Func<T, T>? cloningFunction, DataflowBlockOptions dataflowBlockOptions) 480public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.DataflowBlockOptions; } } 519private readonly DataflowBlockOptions _dataflowBlockOptions; 550DataflowBlockOptions dataflowBlockOptions, 1189internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 1225public DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }
Blocks\BufferBlock.cs (4)
40this(DataflowBlockOptions.Default) 43/// <summary>Initializes the <see cref="BufferBlock{T}"/> with the specified <see cref="DataflowBlockOptions"/>.</summary> 46public BufferBlock(DataflowBlockOptions dataflowBlockOptions) 467public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.DataflowBlockOptions; } }
Blocks\TransformBlock.cs (1)
84/// and <see cref="DataflowBlockOptions"/>.
Blocks\WriteOnceBlock.cs (5)
32private readonly DataflowBlockOptions _dataflowBlockOptions; 53this(cloningFunction, DataflowBlockOptions.Default) 56/// <summary>Initializes the <see cref="WriteOnceBlock{T}"/> with the specified <see cref="DataflowBlockOptions"/>.</summary> 63public WriteOnceBlock(Func<T, T>? cloningFunction, DataflowBlockOptions dataflowBlockOptions) 549public DataflowBlockOptions DataflowBlockOptions { get { return _writeOnceBlock._dataflowBlockOptions; } }
Internal\Common.cs (1)
118IDataflowBlock block, DataflowBlockOptions? options = null)
Internal\DataflowEtwProvider.cs (1)
64internal void DataflowBlockCreated(IDataflowBlock block, DataflowBlockOptions dataflowBlockOptions)
Internal\SourceCore.cs (5)
62private readonly DataflowBlockOptions _dataflowBlockOptions; 103ISourceBlock<TOutput> owningSource, DataflowBlockOptions dataflowBlockOptions, 534internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 822_dataflowBlockOptions.MaxMessagesPerTask == DataflowBlockOptions.Unbounded ? 1014internal DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }
Internal\TargetCore.cs (2)
127if (_dataflowBlockOptions.BoundedCapacity != System.Threading.Tasks.Dataflow.DataflowBlockOptions.Unbounded) 617System.Threading.Tasks.Dataflow.DataflowBlockOptions.Unbounded, "Only valid to use when in bounded mode.");