| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | DataflowBlockOptionsTests.cs | 14 … Assert.Throws<ArgumentNullException>(() => { new DataflowBlockOptions().TaskScheduler = null; }); in TestInvalidArguments()
18 …Assert.Throws<ArgumentOutOfRangeException>(() => { new DataflowBlockOptions().BoundedCapacity = 0;… in TestInvalidArguments()
19 … Assert.Throws<ArgumentNullException>(() => { new DataflowBlockOptions().NameFormat = null; }); in TestInvalidArguments()
31 Action<DataflowBlockOptions> verifyBaseDefaults = dbo => { in TestDefaultValues()
33 … Assert.Equal(expected: DataflowBlockOptions.Unbounded, actual: dbo.MaxMessagesPerTask); in TestDefaultValues()
34 Assert.Equal(expected: DataflowBlockOptions.Unbounded, actual: dbo.BoundedCapacity); in TestDefaultValues()
36 Assert.Equal(expected: -1, actual: DataflowBlockOptions.Unbounded); in TestDefaultValues()
41 verifyBaseDefaults(new DataflowBlockOptions()); in TestDefaultValues()
49 Assert.Equal(expected: DataflowBlockOptions.Unbounded, actual: gdbo.MaxNumberOfGroups); in TestDefaultValues()
56 var dbo = new DataflowBlockOptions(); in TestPropertyRoundtripping()
[all …]
|
| H A D | BufferBlockTests.cs | 20 block = new BufferBlock<int>(new DataflowBlockOptions { MaxMessagesPerTask = 1 }); in TestCtor()
40 new BufferBlock<int>(new DataflowBlockOptions() { NameFormat = nameFormat }) : in TestToString()
50 () => new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage()
75 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1 }) in TestPost()
232 foreach (int maxMessagesPerTask in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
233 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
236 var bb = new BufferBlock<int>(new DataflowBlockOptions in TestProducerConsumer()
450 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1 }) in TestFaultingAndCancellation()
480 var bb = new BufferBlock<int>(new DataflowBlockOptions in TestFaultyScheduler()
510 var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); in TestFaultySource()
[all …]
|
| H A D | WriteOnceBlockTests.cs | 19 new WriteOnceBlock<int>(null, new DataflowBlockOptions()), in TestCtor()
20 new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = 2 }), in TestCtor()
21 …new WriteOnceBlock<int>(null, new DataflowBlockOptions { CancellationToken = new CancellationToken… in TestCtor()
22 new WriteOnceBlock<int>(null, new DataflowBlockOptions { MaxMessagesPerTask = 1 }), in TestCtor()
23 new WriteOnceBlock<int>(null, new DataflowBlockOptions { NameFormat = "" }), in TestCtor()
49 … new WriteOnceBlock<int>(i => i, new DataflowBlockOptions() { NameFormat = nameFormat }) : in TestToString()
59 foreach (int maxMessages in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestLinkToOptions()
109 … () => new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage()
146 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestPost()
236 …var wob = new WriteOnceBlock<int>(null, new DataflowBlockOptions { CancellationToken = cts.Token }… in TestCancellationBeforeAndAfterCtor()
[all …]
|
| H A D | TransformBlockTests.cs | 188 foreach (int maxMessagesPerTask in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
189 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
487 foreach (int dop in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestNullTasksIgnored()
547 [InlineData(DataflowBlockOptions.Unbounded, 1, null)]
548 [InlineData(DataflowBlockOptions.Unbounded, 2, null)]
549 [InlineData(DataflowBlockOptions.Unbounded, DataflowBlockOptions.Unbounded, null)]
552 [InlineData(1, DataflowBlockOptions.Unbounded, null)]
580 [InlineData(DataflowBlockOptions.Unbounded, 1, null)]
581 [InlineData(DataflowBlockOptions.Unbounded, 2, null)]
582 [InlineData(DataflowBlockOptions.Unbounded, DataflowBlockOptions.Unbounded, null)]
[all …]
|
| H A D | TransformManyBlockTests.cs | 192 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
539 foreach (int dop in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestNullTasksIgnored()
599 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 2 }) in TestArrayListReusePossibleForDop1()
656 [InlineData(DataflowBlockOptions.Unbounded, 1, null)]
657 [InlineData(DataflowBlockOptions.Unbounded, 2, null)]
658 [InlineData(DataflowBlockOptions.Unbounded, DataflowBlockOptions.Unbounded, null)]
661 [InlineData(1, DataflowBlockOptions.Unbounded, null)]
689 [InlineData(DataflowBlockOptions.Unbounded, 1, null)]
690 [InlineData(DataflowBlockOptions.Unbounded, 2, null)]
691 [InlineData(DataflowBlockOptions.Unbounded, DataflowBlockOptions.Unbounded, null)]
[all …]
|
| H A D | BroadcastBlockTests.cs | 19 … new BroadcastBlock<int>(i => i, new DataflowBlockOptions { MaxMessagesPerTask = 1 }), in TestCtor()
20 new BroadcastBlock<int>(null, new DataflowBlockOptions { MaxMessagesPerTask = 1 }), in TestCtor()
21 …new BroadcastBlock<int>(i => i, new DataflowBlockOptions { MaxMessagesPerTask = 1, CancellationTok… in TestCtor()
22 …new BroadcastBlock<int>(null, new DataflowBlockOptions { MaxMessagesPerTask = 1, CancellationToken… in TestCtor()
48 … new BroadcastBlock<int>(i => i, new DataflowBlockOptions() { NameFormat = nameFormat }) : in TestToString()
213 …var b = new BroadcastBlock<int>(null, new DataflowBlockOptions { CancellationToken = new Cancellat… in TestPrecancellation()
245 … var bb = new BroadcastBlock<int>(null, new DataflowBlockOptions { BoundedCapacity = 1 }); in TestBounding()
284 var bb = new BroadcastBlock<int>(null, new DataflowBlockOptions { in TestFaultyScheduler()
|
| H A D | DebugAttributeTests.cs | 21 var dboBuffering = new DataflowBlockOptions(); in TestDebuggerDisplaysAndTypeProxies()
22 var dboNoBuffering = new DataflowBlockOptions() { BoundedCapacity = 1 }; in TestDebuggerDisplaysAndTypeProxies()
45 …ple.Create<bool,bool,object>(true, true, new BufferBlock<int>(new DataflowBlockOptions() { NameFor… in TestDebuggerDisplaysAndTypeProxies()
46 …ple.Create<bool,bool,object>(true, true, new BufferBlock<int>(new DataflowBlockOptions() { NameFor… in TestDebuggerDisplaysAndTypeProxies()
47 …ple.Create<bool,bool,object>(true, true, new BufferBlock<int>(new DataflowBlockOptions() { NameFor… in TestDebuggerDisplaysAndTypeProxies()
49 …l,object>(true, false, SendAsyncMessages(new BufferBlock<int>(new DataflowBlockOptions { BoundedCa… in TestDebuggerDisplaysAndTypeProxies()
78 … false, DebuggerAttributes.GetFieldValue(new BufferBlock<int>(new DataflowBlockOptions { BoundedCa… in TestDebuggerDisplaysAndTypeProxies()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | GreedyTest.cs | 38 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoinTest()
40 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoinTest()
68 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test()
70 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test()
72 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test()
103 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoinTest()
105 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoinTest()
135 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test()
137 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test()
139 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test()
[all …]
|
| H A D | BroadcastBlockTest.cs | 94 new DataflowBlockOptions { BoundedCapacity = 1 }); in PostponedTest()
110 new DataflowBlockOptions { TaskScheduler = scheduler }); in ConsumeChangedTest()
137 new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveConsumeChangedTest()
166 new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveChangedTest()
195 new DataflowBlockOptions { TaskScheduler = scheduler }); in QueuedMessagesTest()
220 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in BoundedQueuedTest()
232 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in BoundedPostponedTest()
286 …var block = new BroadcastBlock<int>(i => i * 10, new DataflowBlockOptions { TaskScheduler = schedu… in TryReceiveTest()
307 … var block = new BroadcastBlock<int>(null, new DataflowBlockOptions { TaskScheduler = scheduler }); in TryReceiveAllTest()
326 new DataflowBlockOptions { TaskScheduler = scheduler }); in DontOfferTwiceTest()
|
| H A D | ReceivingTest.cs | 38 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in PostponeTest()
57 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in PostponeTwoTargetsTest()
83 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in DecliningTest()
102 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ConditionalDecliningTest()
143 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveTest()
173 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ConsumeAfterReceiveTest()
203 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in FaultConsume()
225 new DataflowBlockOptions { TaskScheduler = scheduler }); in FaultConsumeBroadcast()
299 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveFaultConsume()
323 new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveFaultConsumeBroadcast()
[all …]
|
| H A D | DataflowBlockTest.cs | 162 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in SendAsyncPostponedAcceptedTest()
180 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in SendAsyncPostponedDeclinedTest()
199 new DataflowBlockOptions { TaskScheduler = scheduler }); in LinkToPredicateTest()
228 new DataflowBlockOptions { TaskScheduler = scheduler }); in LinkToPredicateMaxMessagesTest()
259 new DataflowBlockOptions { TaskScheduler = scheduler }); in LinkToPredicatePostponed()
261 new DataflowBlockOptions { BoundedCapacity = 1, TaskScheduler = scheduler }); in LinkToPredicatePostponed()
284 new DataflowBlockOptions { TaskScheduler = scheduler }); in LinkToPredicateClonerTest()
|
| H A D | OptionsTest.cs | 255 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in MaxMessagesDirectTest()
257 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in MaxMessagesDirectTest()
280 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in MaxMessagesPostponedTest()
282 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesPostponedTest()
313 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in MaxMessagesPostponedUnconsumedTest()
316 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesPostponedUnconsumedTest()
351 null, new DataflowBlockOptions { TaskScheduler = scheduler }); in MaxMessagesBroadcastTest()
353 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesBroadcastTest()
|
| H A D | BatchBlockTest.cs | 168 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTest()
170 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTest()
234 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest()
236 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest()
272 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest2()
274 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest2()
402 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyCompleteDoesnTriggerBatchTest()
|
| H A D | OutputAvailableTest.cs | 35 var source = new BufferBlock<int>(new DataflowBlockOptions{TaskScheduler = scheduler}); in ImmediateTest()
51 var source = new BufferBlock<int>(new DataflowBlockOptions()); in PostponedTest()
78 var source = new BufferBlock<int>(new DataflowBlockOptions()); in CompletedPostponedTest()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/ |
| H A D | DataflowBlockOptions.cs | 56 public class DataflowBlockOptions class
79 internal static readonly DataflowBlockOptions Default = new DataflowBlockOptions();
83 internal DataflowBlockOptions DefaultOrClone() in DefaultOrClone()
87 new DataflowBlockOptions in DefaultOrClone()
98 public DataflowBlockOptions() { } in DataflowBlockOptions() method in System.Threading.Tasks.Dataflow.DataflowBlockOptions
222 public class ExecutionDataflowBlockOptions : DataflowBlockOptions
349 public class GroupingDataflowBlockOptions : DataflowBlockOptions
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/ |
| H A D | DataflowBlockOptions.cs | 61 public class DataflowBlockOptions class
86 internal static readonly DataflowBlockOptions Default = new DataflowBlockOptions();
90 internal DataflowBlockOptions DefaultOrClone() in DefaultOrClone()
94 new DataflowBlockOptions in DefaultOrClone()
106 public DataflowBlockOptions() { } in DataflowBlockOptions() method in System.Threading.Tasks.Dataflow.DataflowBlockOptions
251 public class ExecutionDataflowBlockOptions : DataflowBlockOptions
383 public class GroupingDataflowBlockOptions : DataflowBlockOptions
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
| H A D | ActionBlock.cs | 89 dataflowBlockOptions.BoundedCapacity == DataflowBlockOptions.Unbounded) in ActionBlock()
305 …er(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget.DataflowBlockO… in ToString()
315 …er(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget.DataflowBlockO…
366 public ExecutionDataflowBlockOptions DataflowBlockOptions property in System.Threading.Tasks.Dataflow.ActionBlock.DebugView
368 … _defaultDebugInfo != null ? _defaultDebugInfo.DataflowBlockOptions : _spscDebugInfo.DataflowBlock…
|
| H A D | BufferBlock.cs | 42 this(DataflowBlockOptions.Default) in BufferBlock()
48 public BufferBlock(DataflowBlockOptions dataflowBlockOptions) in BufferBlock()
277 …mmon.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskSchedul… in ConsumeAsyncIfNecessary()
300 int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; in ConsumeMessagesLoopCore()
432 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
441 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
479 …public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.Datafl… property in System.Threading.Tasks.Dataflow.BufferBlock.DebugView
|
| H A D | BroadcastBlock.cs | 57 this(cloningFunction, DataflowBlockOptions.Default) in BroadcastBlock()
67 public BroadcastBlock(Func<T, T> cloningFunction, DataflowBlockOptions dataflowBlockOptions) in BroadcastBlock()
277 …mmon.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskSchedul… in ConsumeAsyncIfNecessary()
299 int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; in ConsumeMessagesLoopCore()
450 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
459 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
495 …public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.Datafl… property in System.Threading.Tasks.Dataflow.BroadcastBlock.DebugView
535 private readonly DataflowBlockOptions _dataflowBlockOptions;
566 DataflowBlockOptions dataflowBlockOptions, in BroadcastingSourceCore()
1210 … internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } property in System.Threading.Tasks.Dataflow.BroadcastBlock.BroadcastingSourceCore
[all …]
|
| H A D | BatchedJoinBlock.cs | 62 …if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) throw new ArgumentExce… in BatchedJoinBlock()
215 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
224 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
267 …taflowBlockOptions DataflowBlockOptions { get { return (GroupingDataflowBlockOptions)_sourceDebugg… property in System.Threading.Tasks.Dataflow.BatchedJoinBlock.DebugView
323 dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) in BatchedJoinBlock()
485 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
494 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
539 …taflowBlockOptions DataflowBlockOptions { get { return (GroupingDataflowBlockOptions)_sourceDebugg… property in System.Threading.Tasks.Dataflow.BatchedJoinBlock.DebugView
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
| H A D | ActionBlock.cs | 88 dataflowBlockOptions.BoundedCapacity == DataflowBlockOptions.Unbounded) in ActionBlock()
304 …er(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget.DataflowBlockO… in ToString()
314 …er(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget.DataflowBlockO…
365 public ExecutionDataflowBlockOptions DataflowBlockOptions property in System.Threading.Tasks.Dataflow.ActionBlock.DebugView
367 … _defaultDebugInfo != null ? _defaultDebugInfo.DataflowBlockOptions : _spscDebugInfo.DataflowBlock…
|
| H A D | BufferBlock.cs | 41 this(DataflowBlockOptions.Default) in BufferBlock()
47 public BufferBlock(DataflowBlockOptions dataflowBlockOptions) in BufferBlock()
276 …mmon.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskSchedul… in ConsumeAsyncIfNecessary()
299 int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; in ConsumeMessagesLoopCore()
430 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
439 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
477 …public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.Datafl… property in System.Threading.Tasks.Dataflow.BufferBlock.DebugView
|
| H A D | BroadcastBlock.cs | 56 this(cloningFunction, DataflowBlockOptions.Default) in BroadcastBlock()
66 public BroadcastBlock(Func<T, T> cloningFunction, DataflowBlockOptions dataflowBlockOptions) in BroadcastBlock()
276 …mmon.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskSchedul… in ConsumeAsyncIfNecessary()
298 int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; in ConsumeMessagesLoopCore()
449 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
458 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
494 …public DataflowBlockOptions DataflowBlockOptions { get { return _sourceDebuggingInformation.Datafl… property in System.Threading.Tasks.Dataflow.BroadcastBlock.DebugView
534 private readonly DataflowBlockOptions _dataflowBlockOptions;
565 DataflowBlockOptions dataflowBlockOptions, in BroadcastingSourceCore()
1209 … internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } property in System.Threading.Tasks.Dataflow.BroadcastBlock.BroadcastingSourceCore
[all …]
|
| H A D | BatchedJoinBlock.cs | 61 …if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) throw new ArgumentExce… in BatchedJoinBlock()
214 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
223 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
266 …taflowBlockOptions DataflowBlockOptions { get { return (GroupingDataflowBlockOptions)_sourceDebugg… property in System.Threading.Tasks.Dataflow.BatchedJoinBlock.DebugView
322 dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) in BatchedJoinBlock()
484 …verride string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } in ToString()
493 Common.GetNameForDebugger(this, _source.DataflowBlockOptions),
538 …taflowBlockOptions DataflowBlockOptions { get { return (GroupingDataflowBlockOptions)_sourceDebugg… property in System.Threading.Tasks.Dataflow.BatchedJoinBlock.DebugView
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/ |
| H A D | Blocks.cs | 30 DataflowBlockOptions dataflowBlockOptions, in CreateBlocksWithOptions()
54 return CreateBlocksWithOptions (new DataflowBlockOptions (), in CreateBlocks()
60 var dataflowBlockOptions = new DataflowBlockOptions { NameFormat = nameFormat }; in CreateBlocksWithNameFormat()
70 var dataflowBlockOptions = new DataflowBlockOptions { CancellationToken = cancellationToken}; in CreateBlocksWithCancellationToken()
|