ProcessMessage()

void System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.ProcessMessage ( Func< TInput, IEnumerable< TOutput > > transformFunction, KeyValuePair< TInput, long > messageWithId )

inlineprivate

Definition at line 163 of file TransformManyBlock.cs.

    {
        bool flag = false;
        try
        {
            IEnumerable<TOutput> outputItems = transformFunction(messageWithId.Key);
            flag = true;
            StoreOutputItems(messageWithId, outputItems);
        }
        catch (Exception exception)
        {
            if (!Common.IsCooperativeCancellation(exception))
            {
                throw;
            }
        }
        finally
        {
            if (!flag)
            {
                StoreOutputItems(messageWithId, null);
            }
        }
    }

References System.exception, System.Threading.Tasks.Dataflow.Internal.Common.IsCooperativeCancellation(), and System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput >.StoreOutputItems().