20 references to AddMessage
System.Threading.Tasks.Dataflow (20)
Blocks\BatchBlock.cs (1)
71
_target = new BatchBlockTargetCore(this, batchSize, _source.
AddMessage
, dataflowBlockOptions);
Blocks\BatchedJoinBlock.cs (2)
77
_source.
AddMessage
(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages()));
325
_source.
AddMessage
(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(), _target3!.GetAndEmptyMessages()));
Blocks\BufferBlock.cs (2)
124
_source.
AddMessage
(messageValue!);
356
_source.
AddMessage
(consumedValue!);
Blocks\JoinBlock.cs (2)
71
_source.
AddMessage
(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage()));
290
() => _source.
AddMessage
(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage(), _target3!.GetOneMessage())),
Blocks\TransformBlock.cs (5)
117
_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.
AddMessage
(message));
205
_source.
AddMessage
(outputItem!);
211
_source.
AddMessage
(outputItem!);
309
_source.
AddMessage
(outputItem!);
315
_source.
AddMessage
(outputItem!);
Blocks\TransformManyBlock.cs (4)
489
_source.
AddMessage
(item);
495
_source.
AddMessage
(item);
511
_source.
AddMessage
(item);
519
_source.
AddMessage
(item);
Blocks\TransformManyBlock.IAsyncEnumerable.cs (4)
225
_source.
AddMessage
(item);
231
_source.
AddMessage
(item);
251
_source.
AddMessage
(item);
260
_source.
AddMessage
(item);