ConsumeMessagesLoopCore()

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

inlineprivate

Definition at line 268 of file BufferBlock.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();
            }
        }
    }

References System.Threading.Tasks.Dataflow.BufferBlock< T >._source, System.Threading.Tasks.Dataflow.DataflowBlockOptions.ActualMaxMessagesPerTask, System.Threading.Tasks.Dataflow.BufferBlock< T >.CompleteCore(), System.Threading.Tasks.Dataflow.BufferBlock< T >.CompleteTargetIfPossible(), System.Threading.Tasks.Dataflow.BufferBlock< T >.ConsumeAndStoreOneMessageIfAvailable(), System.Threading.Tasks.Dataflow.BufferBlock< T >.ConsumeAsyncIfNecessary(), System.Threading.Tasks.Dataflow.Internal.SourceCore< TOutput >.DataflowBlockOptions, System.exception, and System.Threading.Tasks.Dataflow.BufferBlock< T >.IncomingLock.