ConsumeAndStoreOneMessageIfAvailable()

bool System.Threading.Tasks.Dataflow.BroadcastBlock< T >.ConsumeAndStoreOneMessageIfAvailable ( )

inlineprivate

Definition at line 810 of file BroadcastBlock.cs.

    {
        while (true)
        {
            KeyValuePair<ISourceBlock<T>, DataflowMessageHeader> item;
            lock (IncomingLock)
            {
                if (!_boundingState.CountIsLessThanBound)
                {
                    return false;
                }
                if (!_boundingState.PostponedMessages.TryPop(out item))
                {
                    return false;
                }
                _boundingState.CurrentCount++;
            }
            bool messageConsumed = false;
            try
            {
                T item2 = item.Key.ConsumeMessage(item.Value, this, out messageConsumed);
                if (messageConsumed)
                {
                    _source.AddMessage(item2);
                    return true;
                }
            }
            finally
            {
                if (!messageConsumed)
                {
                    lock (IncomingLock)
                    {
                        _boundingState.CurrentCount--;
                    }
                }
            }
        }
    }

References System.Threading.Tasks.Dataflow.BroadcastBlock< T >._boundingState, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._source, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastingSourceCore< TOutput >.AddMessage(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.IncomingLock, and System.item.

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