| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | DelegateBasedMocks.cs | 22 …eFunc(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed); in ConsumeMessageFunc() argument
70 …essage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed) in ConsumeMessage() argument
72 messageConsumed = false; in ConsumeMessage()
74 ConsumeMessageDelegate(messageHeader, target, out messageConsumed) : in ConsumeMessage()
|
| H A D | DataflowTestHelper.cs | 111 …nsumeMessageDelegate = (DataflowMessageHeader _, ITargetBlock<T> __, out bool messageConsumed) => { in TestOfferMessage_AcceptsViaLinking()
112 messageConsumed = false; in TestOfferMessage_AcceptsViaLinking()
|
| H A D | DebugAttributeTests.cs | 214 …eHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) { messageConsumed = tr… in ConsumeMessage() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/mono/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 87 …hreading.Tasks.Dataflow.ITargetBlock<T[]> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
110 …>, System.Collections.Generic.IList<T2>>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
132 …>, System.Collections.Generic.IList<T3>>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
150 ….Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
168 ….Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
274 …ageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed); in ConsumeMessage() argument
296 …taflow.ITargetBlock<System.Tuple<T1, T2>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
317 …ow.ITargetBlock<System.Tuple<T1, T2, T3>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
338 …ding.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
360 …ding.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 86 …hreading.Tasks.Dataflow.ITargetBlock<T[]> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
109 …>, System.Collections.Generic.IList<T2>>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
131 …>, System.Collections.Generic.IList<T3>>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
149 ….Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
167 ….Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
273 …ageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed); in ConsumeMessage() argument
295 …taflow.ITargetBlock<System.Tuple<T1, T2>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
316 …ow.ITargetBlock<System.Tuple<T1, T2, T3>> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
337 …ding.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
359 …ding.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { messageConsumed = de… in ConsumeMessage() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | BoundedCapacityTest.cs | 287 ITargetBlock<T> target, out bool messageConsumed) in ConsumeMessage() argument
295 messageConsumed = true; in ConsumeMessage()
298 messageConsumed = false; in ConsumeMessage()
|
| H A D | EncapsulateTest.cs | 113 out bool messageConsumed) in ConsumeMessage() argument
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
| H A D | WriteOnceBlock.cs | 391 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
402 messageConsumed = true; in ConsumeMessage()
407 messageConsumed = false; in ConsumeMessage()
|
| H A D | BroadcastBlock.cs | 426 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
428 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
1061 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
1076 messageConsumed = false; in ConsumeMessage()
1097 messageConsumed = true; in ConsumeMessage()
|
| H A D | BatchedJoinBlock.cs | 182 …eader messageHeader, ITargetBlock<Tuple<IList<T1>, IList<T2>>> target, out Boolean messageConsumed) in ConsumeMessage() argument
184 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
451 …geHeader, ITargetBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>> target, out Boolean messageConsumed) in ConsumeMessage() argument
453 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
|
| H A D | TransformBlock.cs | 340 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
342 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
|
| H A D | BufferBlock.cs | 205 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
207 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/ |
| H A D | ISourceBlock.cs | 32 …ge(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed); in ConsumeMessage() argument
|
| H A D | DataflowBlock.cs | 160 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
165 return _source.ConsumeMessage(messageHeader, this, out messageConsumed); in ConsumeMessage()
631 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
642 messageConsumed = false; in ConsumeMessage()
666 messageConsumed = true; in ConsumeMessage()
672 messageConsumed = false; in ConsumeMessage()
1695 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
1697 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
2762 bool messageConsumed; in OfferMessage()
2765 source.ConsumeMessage(messageHeader, this, out messageConsumed); in OfferMessage()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/ |
| H A D | ISourceBlock.cs | 31 …ge(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed); in ConsumeMessage() argument
|
| H A D | DataflowBlock.cs | 187 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
192 return _source.ConsumeMessage(messageHeader, this, out messageConsumed); in ConsumeMessage()
658 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
669 messageConsumed = false; in ConsumeMessage()
693 messageConsumed = true; in ConsumeMessage()
699 messageConsumed = false; in ConsumeMessage()
1723 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
1725 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
2790 bool messageConsumed; in OfferMessage()
2793 source.ConsumeMessage(messageHeader, this, out messageConsumed); in OfferMessage()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
| H A D | WriteOnceBlock.cs | 392 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
403 messageConsumed = true; in ConsumeMessage()
408 messageConsumed = false; in ConsumeMessage()
|
| H A D | BroadcastBlock.cs | 427 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
429 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
1062 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
1077 messageConsumed = false; in ConsumeMessage()
1098 messageConsumed = true; in ConsumeMessage()
|
| H A D | BatchedJoinBlock.cs | 183 …eader messageHeader, ITargetBlock<Tuple<IList<T1>, IList<T2>>> target, out Boolean messageConsumed) in ConsumeMessage() argument
185 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
452 …geHeader, ITargetBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>> target, out Boolean messageConsumed) in ConsumeMessage() argument
454 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
|
| H A D | BufferBlock.cs | 206 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
208 return _source.ConsumeMessage(messageHeader, target, out messageConsumed); in ConsumeMessage()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/ref/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 34 …, System.Threading.Tasks.Dataflow.ITargetBlock<T[]> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
55 …c.IList<T1>, System.Collections.Generic.IList<T2>>> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
75 …c.IList<T2>, System.Collections.Generic.IList<T3>>> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
91 …er, System.Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
107 …er, System.Threading.Tasks.Dataflow.ITargetBlock<T> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
209 …ageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed); in ConsumeMessage() argument
229 …g.Tasks.Dataflow.ITargetBlock<System.Tuple<T1, T2>> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
248 …sks.Dataflow.ITargetBlock<System.Tuple<T1, T2, T3>> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
267 …stem.Threading.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
287 …stem.Threading.Tasks.Dataflow.ITargetBlock<TOutput> target, out bool messageConsumed) { throw null… in ConsumeMessage() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/ |
| H A D | SourceCore.cs | 163 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
180 messageConsumed = false; in ConsumeMessage()
194 messageConsumed = false; in ConsumeMessage()
215 messageConsumed = true; in ConsumeMessage()
|
| H A D | TargetRegistry.cs | 335 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
337 return _owningSource.ConsumeMessage(messageHeader, this, out messageConsumed); in ConsumeMessage()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/ |
| H A D | SourceCore.cs | 162 …age(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Boolean messageConsumed) in ConsumeMessage() argument
179 messageConsumed = false; in ConsumeMessage()
193 messageConsumed = false; in ConsumeMessage()
214 messageConsumed = true; in ConsumeMessage()
|
| H A D | TargetRegistry.cs | 335 …meMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean messageConsumed) in ConsumeMessage() argument
337 return _owningSource.ConsumeMessage(messageHeader, this, out messageConsumed); in ConsumeMessage()
|