CreateChooseBranch< T >()

static Task< int > System.Threading.Tasks.Dataflow.DataflowBlock.CreateChooseBranch< T > ( StrongBox< Task > boxedCompleted, CancellationTokenSource cts, TaskScheduler scheduler, int branchId, ISourceBlock< T > source, Action< T > action )

inlinestaticprivate

Definition at line 1664 of file DataflowBlock.cs.

    {
        if (cts.IsCancellationRequested)
        {
            return Common.CreateTaskFromCancellation<int>(cts.Token);
        }
        ChooseTarget<T> chooseTarget = new ChooseTarget<T>(boxedCompleted, cts.Token);
        IDisposable unlink;
        try
        {
            unlink = source.LinkTo(chooseTarget, DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion);
        }
        catch (Exception exception)
        {
            cts.Cancel();
            return Common.CreateTaskFromException<int>(exception);
        }
        return chooseTarget.Task.ContinueWith(delegate(Task<T> completed)
        {
            try
            {
                if (completed.Status == TaskStatus.RanToCompletion)
                {
                    cts.Cancel();
                    action(completed.Result);
                    return branchId;
                }
                return -1;
            }
            finally
            {
                unlink.Dispose();
            }
        }, CancellationToken.None, Common.GetContinuationOptions(), scheduler);
    }

References System.action, System.exception, System.Threading.Tasks.Dataflow.Internal.Common.GetContinuationOptions(), System.Threading.CancellationToken.None, System.scheduler, System.source, and System.Threading.Tasks.Dataflow.DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion.