◆ JoinBlock() [4/4]

System.Threading.Tasks.Dataflow.JoinBlock< T1, T2, T3 >.JoinBlock ( GroupingDataflowBlockOptions dataflowBlockOptions )
inline
Definition at line 257 of file JoinBlock.cs.
    {
        if (dataflowBlockOptions == null)
        {
            throw new ArgumentNullException("dataflowBlockOptions");
        }
        dataflowBlockOptions = dataflowBlockOptions.DefaultOrClone();
        Action<ISourceBlock<Tuple<T1, T2, T3>>, int> itemsRemovedAction = null;
        if (dataflowBlockOptions.BoundedCapacity > 0)
        {
            itemsRemovedAction = delegate(ISourceBlock<Tuple<T1, T2, T3>> owningSource, int count)
            {
                ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.OnItemsRemoved(count);
            };
        }
        _source = new SourceCore<Tuple<T1, T2, T3>>(this, dataflowBlockOptions, delegate(ISourceBlock<Tuple<T1, T2, T3>> owningSource)
        {
            ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.CompleteEachTarget();
        }, itemsRemovedAction);
        JoinBlockTargetBase[] array = new JoinBlockTargetBase[3];
        _sharedResources = new JoinBlockTargetSharedResources(this, array, delegate
        {
            _source.AddMessage(Tuple.Create(_target1.GetOneMessage(), _target2.GetOneMessage(), _target3.GetOneMessage()));
        }, delegate(Exception exception)
        {
            Volatile.Write(ref _sharedResources._hasExceptions, value: true);
            _source.AddException(exception);
        }, dataflowBlockOptions);
        array[0] = (_target1 = new JoinBlockTarget<T1>(_sharedResources));
        array[1] = (_target2 = new JoinBlockTarget<T2>(_sharedResources));
        array[2] = (_target3 = new JoinBlockTarget<T3>(_sharedResources));
        Task.Factory.ContinueWhenAll(new Task[3] { _target1.CompletionTaskInternal, _target2.CompletionTaskInternal, _target3.CompletionTaskInternal }, delegate
        {
            _source.Complete();
        }, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default);
        _source.Completion.ContinueWith(delegate(Task completed, object state)
        {
            IDataflowBlock dataflowBlock = (JoinBlock<T1, T2, T3>)state;
            dataflowBlock.Fault(completed.Exception);
        }, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
        Common.WireCancellationToComplete(dataflowBlockOptions.CancellationToken, _source.Completion, delegate(object state)
        {
            ((JoinBlock<T1, T2, T3>)state)._sharedResources.CompleteEachTarget();
        }, this);
        DataflowEtwProvider log = DataflowEtwProvider.Log;
        if (log.IsEnabled())
        {
            log.DataflowBlockCreated(this, dataflowBlockOptions);
        }
    }