CompleteCore()

void System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteCore ( Exception exception, bool storeExceptionEvenIfAlreadyCompleting, bool revertProcessingState = false )

inlinepackage

Definition at line 669 of file BroadcastBlock.cs.

    {
        lock (IncomingLock)
        {
            if (exception != null && (!_decliningPermanently || storeExceptionEvenIfAlreadyCompleting))
            {
                _source.AddException(exception);
            }
            if (revertProcessingState)
            {
                _boundingState.TaskForInputProcessing = null;
            }
            _decliningPermanently = true;
            CompleteTargetIfPossible();
        }
    }

References System.Threading.Tasks.Dataflow.BroadcastBlock< T >._decliningPermanently, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._source, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastingSourceCore< TOutput >.AddException(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteTargetIfPossible(), System.exception, and System.Threading.Tasks.Dataflow.BroadcastBlock< T >.IncomingLock.

Referenced by System.Threading.Tasks.Dataflow.BroadcastBlock< T >.Complete(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.ConsumeAsyncIfNecessary(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.ConsumeMessagesLoopCore(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.Fault(), and System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastingSourceCore< TOutput >.OfferMessagesLoopCore().