OnItemsRemoved()

void System.Threading.Tasks.Dataflow.BroadcastBlock< T >.OnItemsRemoved ( int numItemsRemoved )

inlineprivate

Definition at line 744 of file BroadcastBlock.cs.

    {
        if (_boundingState != null)
        {
            lock (IncomingLock)
            {
                _boundingState.CurrentCount -= numItemsRemoved;
                ConsumeAsyncIfNecessary();
                CompleteTargetIfPossible();
            }
        }
    }

References System.Threading.Tasks.Dataflow.BroadcastBlock< T >._boundingState, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteTargetIfPossible(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.ConsumeAsyncIfNecessary(), and System.Threading.Tasks.Dataflow.BroadcastBlock< T >.IncomingLock.

Referenced by System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastBlock().