14 implementations of ConsumeMessage
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
151T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed) 618TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed) 1582public TOutput? ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\BatchBlock.cs (1)
155T[]? ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target, out bool messageConsumed)
Blocks\BatchedJoinBlock.cs (2)
173Tuple<IList<T1>, IList<T2>>? ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ConsumeMessage( 427Tuple<IList<T1>, IList<T2>, IList<T3>>? ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ConsumeMessage(
Blocks\BroadcastBlock.cs (1)
415T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
Blocks\BufferBlock.cs (1)
198T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
Blocks\JoinBlock.cs (2)
163Tuple<T1, T2>? ISourceBlock<Tuple<T1, T2>>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target, out bool messageConsumed) 387Tuple<T1, T2, T3>? ISourceBlock<Tuple<T1, T2, T3>>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target, out bool messageConsumed)
Blocks\TransformBlock.cs (1)
371TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\TransformManyBlock.cs (1)
580TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\WriteOnceBlock.cs (1)
375T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
Internal\TargetRegistry.cs (1)
328T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
21 references to ConsumeMessage
System.Threading.Tasks.Dataflow (21)
Base\DataflowBlock.cs (5)
156return _source.ConsumeMessage(messageHeader, this, out messageConsumed); 1168T? acceptedValue = consumeToAccept ? source!.ConsumeMessage(messageHeader, this, out consumed) : messageValue; 1584return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 2114messageValue = source!.ConsumeMessage(messageHeader, this, out consumed)!; 2618source.ConsumeMessage(messageHeader, this, out messageConsumed);
Blocks\BatchBlock.cs (3)
381messageValue = source.ConsumeMessage(messageHeader, _owningBatch, out consumed)!; 996T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed); 1048T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed);
Blocks\BatchedJoinBlock.cs (1)
583messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!;
Blocks\BroadcastBlock.cs (2)
191messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!; 350T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value, this, out consumed);
Blocks\BufferBlock.cs (2)
119messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!; 353T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value, this, out consumed);
Blocks\JoinBlock.cs (3)
645T? consumedValue = _nonGreedy.ReservedMessage.Key.ConsumeMessage(_nonGreedy.ReservedMessage.Value, this, out consumed); 706T? consumedValue = next.Key.ConsumeMessage(next.Value, this, out consumed); 846messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!;
Blocks\WriteOnceBlock.cs (1)
352messageValue = source!.ConsumeMessage(messageHeader, this, out consumed)!;
Internal\SpscTargetCore.cs (1)
144messageValue = source.ConsumeMessage(messageHeader, _owningTarget, out consumed)!;
Internal\TargetCore.cs (2)
211messageValue = source.ConsumeMessage(messageHeader, _owningTarget, out consumed)!; 671TInput? consumedValue = element.Key.ConsumeMessage(element.Value, _owningTarget, out consumed);
Internal\TargetRegistry.cs (1)
330return _owningSource.ConsumeMessage(messageHeader, this, out messageConsumed);