1 write to _source
System.Threading.Tasks.Dataflow (1)
20 references to _source
System.Threading.Tasks.Dataflow (20)
Blocks\BatchBlock.cs (20)
71_target = new BatchBlockTargetCore(this, batchSize, _source.AddMessage, dataflowBlockOptions);
74_target.Completion.ContinueWith(delegate { _source.Complete(); },
81_source.Completion.ContinueWith(static (completed, state) =>
90dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchBlockTargetCore)state!).Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), _target);
123return _source.LinkTo(target, linkOptions);
129return _source.TryReceive(filter, out item);
133public bool TryReceiveAll([NotNullWhen(true)] out IList<T[]>? items) { return _source.TryReceiveAll(out items); }
136public int OutputCount { get { return _source.OutputCount; } }
139public Task Completion { get { return _source.Completion; } }
157return _source.ConsumeMessage(messageHeader, target, out messageConsumed);
163return _source.ReserveMessage(messageHeader, target);
169_source.ReleaseReservation(messageHeader, target);
173private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } }
176public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); }
180$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}";
202_sourceDebuggingInformation = batchBlock._source.GetDebuggingInformation();
437_owningBatch._source.AddException(exception);
449catch (Exception e) { _owningBatch._source.AddException(e); }
480return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions;
540targetCore._owningBatch._source.AddExceptions(exceptions);