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()));
328
_source.
AddMessage
(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(), _target3!.GetAndEmptyMessages()));
Blocks\BufferBlock.cs (2)
127
_source.
AddMessage
(messageValue!);
362
_source.
AddMessage
(consumedValue!);
Blocks\JoinBlock.cs (2)
74
_source.
AddMessage
(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage()));
299
() => _source.
AddMessage
(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage(), _target3!.GetOneMessage())),
Blocks\TransformBlock.cs (5)
120
_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.
AddMessage
(message));
208
_source.
AddMessage
(outputItem!);
214
_source.
AddMessage
(outputItem!);
312
_source.
AddMessage
(outputItem!);
318
_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)
228
_source.
AddMessage
(item);
234
_source.
AddMessage
(item);
254
_source.
AddMessage
(item);
263
_source.
AddMessage
(item);