ProcessMessageWithTask()

void System.Threading.Tasks.Dataflow.ActionBlock< TInput >.ProcessMessageWithTask ( Func< TInput, Task > action, KeyValuePair< TInput, long > messageWithId )

inlineprivate

Definition at line 240 of file ActionBlock.cs.

    {
        Task task = null;
        Exception ex = null;
        try
        {
            task = action(messageWithId.Key);
        }
        catch (Exception ex2)
        {
            ex = ex2;
        }
        if (task == null)
        {
            if (ex != null && !Common.IsCooperativeCancellation(ex))
            {
                Common.StoreDataflowMessageValueIntoExceptionData(ex, messageWithId.Key);
                _defaultTarget.Complete(ex, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true);
            }
            _defaultTarget.SignalOneAsyncMessageCompleted(-1);
        }
        else if (task.IsCompleted)
        {
            AsyncCompleteProcessMessageWithTask(task);
        }
        else
        {
            task.ContinueWith(delegate(Task completed, object state)
            {
                ((ActionBlock<TInput>)state).AsyncCompleteProcessMessageWithTask(completed);
            }, this, CancellationToken.None, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default);
        }
    }

References System.Threading.Tasks.Dataflow.ActionBlock< TInput >._defaultTarget, System.action, System.Threading.Tasks.Dataflow.ActionBlock< TInput >.AsyncCompleteProcessMessageWithTask(), System.Threading.Tasks.TaskScheduler.Default, System.Threading.Tasks.Dataflow.Internal.Common.GetContinuationOptions(), System.Threading.Tasks.Dataflow.Internal.Common.IsCooperativeCancellation(), System.Threading.CancellationToken.None, System.state, and System.task.