| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | ActionBlockTests.cs | 19 new ActionBlock<int>(i => { })); in TestToString()
33 () => new ActionBlock<int>(i => { }), in TestOfferMessage()
58 ActionBlock<int> ab = new ActionBlock<int>(i => { }, in TestPost()
84 new ActionBlock<int>(i => { }), in TestCtor()
214 ActionBlock<int> ab = sync ? in TestInputCount()
248 ActionBlock<int> ab = sync ? in TestOrderMaintained()
266 ActionBlock<int> ab = sync ? in TestNonGreedy()
319 ActionBlock<int> ab = sync ? in TestOperationCanceledExceptionsIgnored()
378 ActionBlock<int> ab = null; in TestFaulting()
429 ActionBlock<int> ab = sync ? in TestParallelExecution()
[all …]
|
| H A D | SimpleNetworkTests.cs | 21 var c = new ActionBlock<int>(i => in TransformToAction()
42 var c = new ActionBlock<int>(i => completedCount++); in TransformThroughFilterToAction()
58 var c = new ActionBlock<int>(i => completedCount++); in TransformThroughDiscardingFilterToAction()
83 var last = new ActionBlock<int>(i => completedCount++); in TenTransformsToAction()
98 var c = new ActionBlock<int[]>(i => completedCount++); in BatchGreedyToAction()
112 var c = new ActionBlock<int>(i => completedCount++); in WriteOnceToAction()
155 var c = new ActionBlock<int[]>(i => completedCount++); in BufferBlocksToBatchNonGreedyToAction()
199 var c = new ActionBlock<int>(i => completedCount++); in TransformManyEnumerableToAction()
214 ActionBlock<int> c1 = null, c2 = null; in ActionPingPong()
215 c1 = new ActionBlock<int>(i => c2.Post(i + 1)); in ActionPingPong()
[all …]
|
| H A D | DebugAttributeTests.cs | 34 Tuple.Create<bool,bool,object>(true, true, new ActionBlock<int>(i => {})), in TestDebuggerDisplaysAndTypeProxies()
35 … Tuple.Create<bool,bool,object>(true, true, new ActionBlock<int>(i => {}, dboExBuffering)), in TestDebuggerDisplaysAndTypeProxies()
36 … Tuple.Create<bool,bool,object>(true, true, new ActionBlock<int>(i => {}, dboExSpsc)), in TestDebuggerDisplaysAndTypeProxies()
37 …Tuple.Create<bool,bool,object>(true, false, SendAsyncMessages(new ActionBlock<int>(i => {}, dboExN… in TestDebuggerDisplaysAndTypeProxies()
72 …te<bool,bool,object>(true, false, DebuggerAttributes.GetFieldValue(new ActionBlock<int>(i => {}, d… in TestDebuggerDisplaysAndTypeProxies()
73 …te<bool,bool,object>(true, false, DebuggerAttributes.GetFieldValue(new ActionBlock<int>(i => {}, d… in TestDebuggerDisplaysAndTypeProxies()
74 … DebuggerAttributes.GetFieldValue(DebuggerAttributes.GetFieldValue(new ActionBlock<int>(i => {}), … in TestDebuggerDisplaysAndTypeProxies()
75 …te<bool,bool,object>(true, false, DebuggerAttributes.GetFieldValue(new ActionBlock<int>(i => {}, d… in TestDebuggerDisplaysAndTypeProxies()
76 … DebuggerAttributes.GetFieldValue(DebuggerAttributes.GetFieldValue(new ActionBlock<int>(i => {}, d… in TestDebuggerDisplaysAndTypeProxies()
92 …reate<bool,bool,object>(true, false, new BufferBlock<int>().LinkTo(new ActionBlock<int>(i => {})))… in TestDebuggerDisplaysAndTypeProxies()
|
| H A D | BroadcastBlockTests.cs | 128 using (b.LinkTo(new ActionBlock<int>(i => { }))) in TestLinkingAfterCompletion()
129 using (b.LinkTo(new ActionBlock<int>(i => { }))) in TestLinkingAfterCompletion()
139 var ab = new ActionBlock<int>(i => { }); in TestLinkingToCompleted()
169 var target = new ActionBlock<int>(i => { in TestCloning()
199 var target = new ActionBlock<object>(o => { in TestCloning()
246 var ab = new ActionBlock<int>(i => { }); in TestBounding()
|
| H A D | EtwTests.cs | 20 ActionBlock<int> ab = null; in TestEtw()
33 ab = new ActionBlock<int>(i => { }); in TestEtw()
|
| H A D | DataflowBlockExtensionTests.cs | 183 var ab = new ActionBlock<int>(i => { in TestAsObservableAndAsObserver_DataPropagation()
195 var ab = new ActionBlock<int>(i => { in TestAsObservableAndAsObserver_DataPropagation()
445 var target = new ActionBlock<int>(i => { }); in TestLinkTo_ArgumentValidation()
577 var target = new ActionBlock<int>(i => counter++); in TestLinkTo_BasicLinking()
612 var target = new ActionBlock<int>(i => counter++); in TestLinkTo_Predicate()
674 var targets = new ActionBlock<int>[6]; in TestLinkTo_Append()
716 target = new ActionBlock<int>(i => { }); in TestLinkTo_PropagateCompletion()
722 target = new ActionBlock<int>(i => { }); in TestLinkTo_PropagateCompletion()
1751 encapsulated.LinkTo(new ActionBlock<int>(x => { })); in TestEncapsulate_EncapsulateBoundedTarget()
1832 var target = new ActionBlock<int>(i => { }); in TestEncapsulate_CompleteAndFaultPassthrough()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
| H A D | ActionBlock.cs | 26 [DebuggerTypeProxy(typeof(ActionBlock<>.DebugView))]
27 public sealed class ActionBlock<TInput> : ITargetBlock<TInput>, IDebuggerDisplay class
37 public ActionBlock(Action<TInput> action) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
46 … public ActionBlock(Action<TInput> action, ExecutionDataflowBlockOptions dataflowBlockOptions) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
53 public ActionBlock(Func<TInput, Task> action) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
62 …public ActionBlock(Func<TInput, Task> action, ExecutionDataflowBlockOptions dataflowBlockOptions) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
71 private ActionBlock(Delegate action, ExecutionDataflowBlockOptions dataflowBlockOptions) in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
193 ((ActionBlock<TInput>)state).AsyncCompleteProcessMessageWithTask(completed); in ProcessMessageWithTask()
326 private readonly ActionBlock<TInput> _actionBlock;
334 public DebugView(ActionBlock<TInput> actionBlock) in DebugView()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
| H A D | ActionBlock.cs | 25 [DebuggerTypeProxy(typeof(ActionBlock<>.DebugView))]
26 public sealed class ActionBlock<TInput> : ITargetBlock<TInput>, IDebuggerDisplay class
36 public ActionBlock(Action<TInput> action) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
45 … public ActionBlock(Action<TInput> action, ExecutionDataflowBlockOptions dataflowBlockOptions) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
52 public ActionBlock(Func<TInput, Task> action) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
61 …public ActionBlock(Func<TInput, Task> action, ExecutionDataflowBlockOptions dataflowBlockOptions) : in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
70 private ActionBlock(Delegate action, ExecutionDataflowBlockOptions dataflowBlockOptions) in ActionBlock() method in System.Threading.Tasks.Dataflow.ActionBlock
192 ((ActionBlock<TInput>)state).AsyncCompleteProcessMessageWithTask(completed); in ProcessMessageWithTask()
325 private readonly ActionBlock<TInput> _actionBlock;
333 public DebugView(ActionBlock<TInput> actionBlock) in DebugView()
|
| /dports/security/vuls/vuls-0.13.7/vendor/github.com/nlopes/slack/ |
| H A D | block_action.go | 6 type ActionBlock struct { struct
13 func (s ActionBlock) BlockType() MessageBlockType { argument
18 func NewActionBlock(blockID string, elements ...BlockElement) *ActionBlock {
19 return &ActionBlock{
|
| /dports/www/beehive/beehive-0.4.0/vendor/github.com/nlopes/slack/ |
| H A D | block_action.go | 6 type ActionBlock struct { struct
13 func (s ActionBlock) BlockType() MessageBlockType { argument
18 func NewActionBlock(blockID string, elements ...BlockElement) *ActionBlock {
19 return &ActionBlock{
|
| /dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/slack-go/slack/ |
| H A D | block_action.go | 6 type ActionBlock struct { struct
13 func (s ActionBlock) BlockType() MessageBlockType { argument
18 func NewActionBlock(blockID string, elements ...BlockElement) *ActionBlock {
19 return &ActionBlock{
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/slack-go/slack/ |
| H A D | block_action.go | 6 type ActionBlock struct { struct
13 func (s ActionBlock) BlockType() MessageBlockType { argument
18 func NewActionBlock(blockID string, elements ...BlockElement) *ActionBlock {
19 return &ActionBlock{
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/redjack/marionette/mar/ |
| H A D | ast.go | 14 func (*ActionBlock) node() {}
33 ActionBlocks []*ActionBlock
45 func (doc *Document) ActionBlock(name string) *ActionBlock { func
68 …ppend(doc.Transitions, &Transition{Source: "end", Destination: "dead", ActionBlock: "NULL", Probab…
71 …pend(doc.Transitions, &Transition{Source: "dead", Destination: "dead", ActionBlock: "NULL", Probab…
81 ActionBlock string member
182 type ActionBlock struct { struct
294 case *ActionBlock:
|
| H A D | parser.go | 156 transition.ActionBlock = lit
171 func (p *Parser) parseActionBlocks(scanner *Scanner) ([]*ActionBlock, error) {
172 var blks []*ActionBlock
187 func (p *Parser) parseActionBlock(scanner *Scanner) (*ActionBlock, error) {
188 var blk ActionBlock
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/redjack/marionette/mar/ |
| H A D | ast.go | 14 func (*ActionBlock) node() {}
33 ActionBlocks []*ActionBlock
45 func (doc *Document) ActionBlock(name string) *ActionBlock { func
68 …ppend(doc.Transitions, &Transition{Source: "end", Destination: "dead", ActionBlock: "NULL", Probab…
71 …pend(doc.Transitions, &Transition{Source: "dead", Destination: "dead", ActionBlock: "NULL", Probab…
81 ActionBlock string member
182 type ActionBlock struct { struct
294 case *ActionBlock:
|
| H A D | parser.go | 156 transition.ActionBlock = lit
171 func (p *Parser) parseActionBlocks(scanner *Scanner) ([]*ActionBlock, error) {
172 var blks []*ActionBlock
187 func (p *Parser) parseActionBlock(scanner *Scanner) (*ActionBlock, error) {
188 var blk ActionBlock
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | WriteOnceBlockTest.cs | 44 var action1 = new ActionBlock<int> (i => in BasicUsageTest()
49 var action2 = new ActionBlock<int> (i => in BasicUsageTest()
74 var action = new ActionBlock<int> (i => in LinkAfterPostTest()
134 var action1 = new ActionBlock<object> (i => in CloningTest()
139 var action2 = new ActionBlock<object> (i => in CloningTest()
167 var action1 = new ActionBlock<int> (i => in WriteOnceBehaviorTest()
172 var action2 = new ActionBlock<int> (i => in WriteOnceBehaviorTest()
|
| H A D | ActionBlockTest.cs | 44 var block = new ActionBlock<int> (i => { array[i] = true; evt.Signal (); }); in BasicUsageTest()
57 var block = new ActionBlock<int> (i => Thread.Sleep (100)); in CompleteTest()
73 var block = new ActionBlock<int> ( in AsyncNullTest()
92 var block = new ActionBlock<int> ( in AsyncCancelledTest()
|
| H A D | BufferBlockTest.cs | 43 var action = new ActionBlock<int> (i => in BasicUsageTest()
64 var block = new ActionBlock<int> (i => evt.Signal ()); in LateBindingTest()
78 var block = new ActionBlock<int> (i => in MultipleBindingTest()
93 var block2 = new ActionBlock<int> (i => in MultipleBindingTest()
|
| H A D | CompletionTest.cs | 147 var actionBlock = new ActionBlock<int> (_ => evt.Wait ()); in MultipleFaultsWhileExecutingTest()
178 var block = new ActionBlock<int> ( in MultipleExceptionsTest()
200 var block = new ActionBlock<int> ( in ExceptionAndFaultTest()
221 var block = new ActionBlock<int> ( in FaultAndExceptionTest()
250 var block = new ActionBlock<int> ( in ExceptionAndCancelTest()
274 var block = new ActionBlock<int> ( in CancelAndExceptionTest()
324 var block = new ActionBlock<int> ( in CancelAndFaultWhileExecutingTest()
356 var block = new ActionBlock<int> ( in FaultAndCancelWhileExecutingTest()
|
| H A D | TransformManyBlockTest.cs | 47 …var block = new ActionBlock<int> (i => { array[Interlocked.Increment (ref insIndex)] = i; evt.Sign… in BasicUsageTest()
66 …var block = new ActionBlock<int> (i => { array[Interlocked.Increment (ref insIndex)] = i; evt.Sign… in DeferredUsageTest()
85 var action = new ActionBlock<int> (i => received = true); in NullResultTest()
|
| H A D | BroadcastBlockTest.cs | 45 var action1 = new ActionBlock<int> (i => in BasicUsageTest()
50 var action2 = new ActionBlock<int> (i => in BasicUsageTest()
74 var action = new ActionBlock<int> (i => in LinkAfterPostTest()
256 var action1 = new ActionBlock<object> (i => in CloningTest()
261 var action2 = new ActionBlock<object> (i => in CloningTest()
|
| H A D | TransformBlockTest.cs | 44 var action = new ActionBlock<int> (i => in BasicUsageTest()
65 var action = new ActionBlock<int> (i => array[Math.Abs (i)] = i); in DeferredUsageTest()
|
| H A D | BatchBlockTest.cs | 44 var block = new ActionBlock<int[]> (i => in BasicUsageTest()
72 var block = new ActionBlock<int[]> (i => in TriggerBatchTest()
100 var block = new ActionBlock<int[]> (i => in TriggerBatchLateBinding()
126 var block = new ActionBlock<int[]> (i => in LateTriggerBatchKeepCountTest()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/ |
| H A D | Blocks.cs | 34 yield return new ActionBlock<int> (i => { }, executionDataflowBlockOptions); in CreateBlocksWithOptions()
91 yield return new ActionBlock<T> (i => { }); in CreateTargetBlocks()
|