Complete

6 references to Complete

System.Threading.Tasks.Dataflow (6)

Blocks\BatchBlock.cs (6)

67static owningSource => ((BatchBlock<T>)owningSource)._target.Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), 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); 657Task.Factory.StartNew(exc => Complete(exception: (Exception)exc!, dropPendingMessages: true, releaseReservedMessages: true, revertProcessingState: true), 704Complete(exc, dropPendingMessages: false, releaseReservedMessages: true);