1 write to _target
System.Threading.Tasks.Dataflow (1)
10 references to _target
System.Threading.Tasks.Dataflow (10)
Blocks\BatchBlock.cs (10)
61onItemsRemoved = static (owningSource, count) => ((BatchBlock<T>)owningSource)._target.OnItemsRemoved(count);
67static owningSource => ((BatchBlock<T>)owningSource)._target.Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false),
74_target.Completion.ContinueWith(delegate { _source.Complete(); },
90dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchBlockTargetCore)state!).Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), _target);
99public void Complete() { _target.Complete(exception: null, dropPendingMessages: false, releaseReservedMessages: false); }
109_target.Complete(exception, dropPendingMessages: true, releaseReservedMessages: false);
121public void TriggerBatch() { _target.TriggerBatch(); }
149public int BatchSize { get { return _target.BatchSize; } }
154return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept);
204_targetDebuggingInformation = batchBlock._target.GetDebuggingInformation();