ProcessMessage()

void System.Threading.Tasks.Dataflow.ActionBlock< TInput >.ProcessMessage ( Action< TInput > action, KeyValuePair< TInput, long > messageWithId )

inlineprivate

Definition at line 218 of file ActionBlock.cs.

    {
        try
        {
            action(messageWithId.Key);
        }
        catch (Exception exception)
        {
            if (!Common.IsCooperativeCancellation(exception))
            {
                throw;
            }
        }
        finally
        {
            if (_defaultTarget.IsBounded)
            {
                _defaultTarget.ChangeBoundingCount(-1);
            }
        }
    }

References System.Threading.Tasks.Dataflow.ActionBlock< TInput >._defaultTarget, System.action, System.exception, and System.Threading.Tasks.Dataflow.Internal.Common.IsCooperativeCancellation().