CompleteTargetIfPossible()

void System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteTargetIfPossible ( )

inlineprivate

Definition at line 850 of file BroadcastBlock.cs.

    {
        if (!_decliningPermanently || _completionReserved || (_boundingState != null && _boundingState.TaskForInputProcessing != null))
        {
            return;
        }
        _completionReserved = true;
        if (_boundingState != null && _boundingState.PostponedMessages.Count > 0)
        {
            Task.Factory.StartNew(delegate(object state)
            {
                BroadcastBlock<T> broadcastBlock = (BroadcastBlock<T>)state;
                List<Exception> exceptions = null;
                if (broadcastBlock._boundingState != null)
                {
                    Common.ReleaseAllPostponedMessages(broadcastBlock, broadcastBlock._boundingState.PostponedMessages, ref exceptions);
                }
                if (exceptions != null)
                {
                    broadcastBlock._source.AddExceptions(exceptions);
                }
                broadcastBlock._source.Complete();
            }, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
        }
        else
        {
            _source.Complete();
        }
    }

References System.Threading.Tasks.Dataflow.BroadcastBlock< T >._boundingState, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._completionReserved, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._decliningPermanently, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._source, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastingSourceCore< TOutput >.Complete(), System.Threading.Tasks.TaskScheduler.Default, System.exceptions, System.Threading.Tasks.Task< TResult >.Factory, System.Threading.Tasks.Dataflow.Internal.Common.GetCreationOptionsForTask(), System.Threading.CancellationToken.None, System.state, and System.Threading.Tasks.Dataflow.Internal.BoundingStateWithPostponedAndTask< TInput >.TaskForInputProcessing.

Referenced by System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteCore(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.ConsumeMessagesLoopCore(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.OfferMessage(), and System.Threading.Tasks.Dataflow.BroadcastBlock< T >.OnItemsRemoved().