◆ ConsumeMessagesLoopCore()

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

inlineprivate

Definition at line 782 of file BroadcastBlock.cs.

    {
        try
        {
            int actualMaxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask;
            for (int i = 0; i < actualMaxMessagesPerTask; i++)
            {
                if (!ConsumeAndStoreOneMessageIfAvailable())
                {
                    break;
                }
            }
        }
        catch (Exception exception)
        {
            CompleteCore(exception, storeExceptionEvenIfAlreadyCompleting: true);
        }
        finally
        {
            lock (IncomingLock)
            {
                _boundingState.TaskForInputProcessing = null;
                ConsumeAsyncIfNecessary(isReplacementReplica: true);
                CompleteTargetIfPossible();
            }
        }
    }