ChooseCoreByLinking< T1, T2, T3 >()

static Task< int > System.Threading.Tasks.Dataflow.DataflowBlock.ChooseCoreByLinking< T1, T2, T3 > ( ISourceBlock< T1 > source1, Action< T1 > action1, ISourceBlock< T2 > source2, Action< T2 > action2, ISourceBlock< T3 > source3, Action< T3 > action3, DataflowBlockOptions dataflowBlockOptions )

inlinestaticprivate

Definition at line 1611 of file DataflowBlock.cs.

    {
        bool flag = source3 != null;
        StrongBox<Task> boxedCompleted = new StrongBox<Task>();
        CancellationTokenSource cts = CancellationTokenSource.CreateLinkedTokenSource(dataflowBlockOptions.CancellationToken, CancellationToken.None);
        TaskScheduler taskScheduler = dataflowBlockOptions.TaskScheduler;
        Task<int>[] array = new Task<int>[flag ? 3 : 2];
        array[0] = CreateChooseBranch(boxedCompleted, cts, taskScheduler, 0, source1, action1);
        array[1] = CreateChooseBranch(boxedCompleted, cts, taskScheduler, 1, source2, action2);
        if (flag)
        {
            array[2] = CreateChooseBranch(boxedCompleted, cts, taskScheduler, 2, source3, action3);
        }
        TaskCompletionSource<int> result = new TaskCompletionSource<int>();
        Task.Factory.ContinueWhenAll(array, delegate(Task<int>[] tasks)
        {
            List<Exception> list = null;
            int num = -1;
            foreach (Task<int> task in tasks)
            {
                switch (task.Status)
                {
                case TaskStatus.Faulted:
                    Common.AddException(ref list, task.Exception, unwrapInnerExceptions: true);
                    break;
                case TaskStatus.RanToCompletion:
                {
                    int result2 = task.Result;
                    if (result2 >= 0)
                    {
                        num = result2;
                    }
                    break;
                }
                }
            }
            if (list != null)
            {
                result.TrySetException(list);
            }
            else if (num >= 0)
            {
                result.TrySetResult(num);
            }
            else
            {
                result.TrySetCanceled();
            }
            cts.Dispose();
        }, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default);
        return result.Task;
    }

References System.array, System.Threading.CancellationTokenSource.CreateLinkedTokenSource(), System.Threading.Tasks.Task< TResult >.Factory, System.list, System.Threading.CancellationToken.None, System.task, and System.tasks.