14 implementations of ConsumeMessage
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
169T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed) 642TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed) 1627public TOutput? ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\BatchBlock.cs (1)
158T[]? ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target, out bool messageConsumed)
Blocks\BatchedJoinBlock.cs (2)
176Tuple<IList<T1>, IList<T2>>? ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ConsumeMessage( 433Tuple<IList<T1>, IList<T2>, IList<T3>>? ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ConsumeMessage(
Blocks\BroadcastBlock.cs (1)
421T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
Blocks\BufferBlock.cs (1)
204T? ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target, out bool messageConsumed)
Blocks\JoinBlock.cs (2)
169Tuple<T1, T2>? ISourceBlock<Tuple<T1, T2>>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target, out bool messageConsumed) 399Tuple<T1, T2, T3>? ISourceBlock<Tuple<T1, T2, T3>>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target, out bool messageConsumed)
Blocks\TransformBlock.cs (1)
377TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\TransformManyBlock.cs (1)
583TOutput? ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target, out bool messageConsumed)
Blocks\WriteOnceBlock.cs (1)
387T? 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)
174return _source.ConsumeMessage(messageHeader, this, out messageConsumed); 1201T? acceptedValue = consumeToAccept ? source!.ConsumeMessage(messageHeader, this, out consumed) : messageValue; 1629return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 2195messageValue = source!.ConsumeMessage(messageHeader, this, out consumed)!; 2708source.ConsumeMessage(messageHeader, this, out messageConsumed);
Blocks\BatchBlock.cs (3)
384messageValue = source.ConsumeMessage(messageHeader, _owningBatch, out consumed)!; 999T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed); 1051T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed);
Blocks\BatchedJoinBlock.cs (1)
589messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!;
Blocks\BroadcastBlock.cs (2)
197messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!; 356T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value, this, out consumed);
Blocks\BufferBlock.cs (2)
122messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!; 359T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value, this, out consumed);
Blocks\JoinBlock.cs (3)
657T? consumedValue = _nonGreedy.ReservedMessage.Key.ConsumeMessage(_nonGreedy.ReservedMessage.Value, this, out consumed); 718T? consumedValue = next.Key.ConsumeMessage(next.Value, this, out consumed); 858messageValue = source.ConsumeMessage(messageHeader, this, out consumed)!;
Blocks\WriteOnceBlock.cs (1)
364messageValue = 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);