| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/ |
| H A D | ISourceBlock.cs | 32 …TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Bool… in ConsumeMessage() method
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/ |
| H A D | ISourceBlock.cs | 31 …TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out Bool… in ConsumeMessage() method
|
| /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 …T[] System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage(System.Threading.Tasks.Datafl… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchBlock
55 …Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
75 …Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
91 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
107 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
209 …TOutput ConsumeMessage(System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System… in ConsumeMessage() method
229 …2> System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
248 …System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2,T3>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
267 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
287 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformManyBlock
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/mono/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 87 …T[] System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage(System.Threading.Tasks.Datafl… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchBlock
110 …Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
132 …Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
150 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
168 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
274 …TOutput ConsumeMessage(System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System… in ConsumeMessage() method
296 …2> System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
317 …System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2,T3>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
338 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
360 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformManyBlock
[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 …T[] System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage(System.Threading.Tasks.Datafl… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchBlock
109 …Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
131 …Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
149 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
167 …T System.Threading.Tasks.Dataflow.ISourceBlock<T>.ConsumeMessage(System.Threading.Tasks.Dataflow.D… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
273 …TOutput ConsumeMessage(System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System… in ConsumeMessage() method
295 …2> System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
316 …System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<T1,T2,T3>>.ConsumeMessage(System.Threadi… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.JoinBlock
337 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
359 …TOutput System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>.ConsumeMessage(System.Threading.Task… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformManyBlock
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | EncapsulateTest.cs | 111 public TOutput ConsumeMessage (DataflowMessageHeader messageHeader, in ConsumeMessage() method in MonoTests.System.Threading.Tasks.Dataflow.CompletionCheckerBlock
|
| H A D | BoundedCapacityTest.cs | 286 public T ConsumeMessage (DataflowMessageHeader messageHeader, in ConsumeMessage() method in MonoTests.System.Threading.Tasks.Dataflow.TestSourceBlock
|
| /dports/security/keybase/client-v5.7.1/go/protocol/gregor1/ |
| H A D | incoming.go | 129 ConsumeMessage(context.Context, Message) error methodSpec
307 func (c IncomingClient) ConsumeMessage(ctx context.Context, m Message) (err error) { func
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | DebugAttributeTests.cs | 214 …public T ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out Boolean m… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Tests.DebugAttributeTests.StoreLinkedTarget
|
| H A D | DelegateBasedMocks.cs | 70 …public TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, o… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Tests.DelegatePropagator
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
| H A D | BroadcastBlock.cs | 427 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
1062 …internal TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target,… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock.BroadcastingSourceCore
|
| H A D | BufferBlock.cs | 206 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
|
| H A D | WriteOnceBlock.cs | 392 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.WriteOnceBlock
|
| H A D | BatchedJoinBlock.cs | 182 Tuple<IList<T1>, IList<T2>> ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ConsumeMessage( in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
451 …ist<T1>, IList<T2>, IList<T3>> ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ConsumeMessage( in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
|
| H A D | TransformBlock.cs | 378 …TOutput ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOu… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
| H A D | BroadcastBlock.cs | 426 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
1061 …internal TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target,… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock.BroadcastingSourceCore
|
| H A D | BufferBlock.cs | 205 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
|
| H A D | WriteOnceBlock.cs | 391 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.WriteOnceBlock
|
| H A D | BatchedJoinBlock.cs | 181 Tuple<IList<T1>, IList<T2>> ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ConsumeMessage( in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
450 …ist<T1>, IList<T2>, IList<T3>> ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ConsumeMessage( in ConsumeMessage() method in System.Threading.Tasks.Dataflow.BatchedJoinBlock
|
| H A D | TransformBlock.cs | 340 …TOutput ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOu… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
|
| /dports/security/keybase/client-v5.7.1/go/service/ |
| H A D | gregor_test.go | 305 func (m mockGregord) ConsumeMessage(ctx context.Context, msg gregor1.Message) error { func
1050 func (f flakeyIncomingClient) ConsumeMessage(ctx context.Context, m gregor1.Message) error { func
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/ |
| H A D | TargetRegistry.cs | 335 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Internal.TargetRegistry.NopLinkPropagator
|
| H A D | SourceCore.cs | 163 …internal TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target,… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Internal.SourceCore
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/ |
| H A D | TargetRegistry.cs | 335 …T ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out … in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Internal.TargetRegistry.NopLinkPropagator
|
| H A D | SourceCore.cs | 162 …internal TOutput ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target,… in ConsumeMessage() method in System.Threading.Tasks.Dataflow.Internal.SourceCore
|