◆ WriteOnceBlock() [2/2]

System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.WriteOnceBlock	(	Func< T, T >?	cloningFunction,
		DataflowBlockOptions	dataflowBlockOptions )

inline

Definition at line 89 of file WriteOnceBlock.cs.

    {
        if (dataflowBlockOptions == null)
        {
            throw new ArgumentNullException("dataflowBlockOptions");
        }
        _cloningFunction = cloningFunction;
        _dataflowBlockOptions = dataflowBlockOptions.DefaultOrClone();
        _targetRegistry = new TargetRegistry<T>(this);
        if (dataflowBlockOptions.CancellationToken.CanBeCanceled)
        {
            _lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>();
            if (dataflowBlockOptions.CancellationToken.IsCancellationRequested)
            {
                _completionReserved = (_decliningPermanently = true);
                _lazyCompletionTaskSource.SetCanceled();
            }
            else
            {
                Common.WireCancellationToComplete(dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, delegate(object state)
                {
                    ((WriteOnceBlock<T>)state).Complete();
                }, this);
            }
        }
        DataflowEtwProvider log = DataflowEtwProvider.Log;
        if (log.IsEnabled())
        {
            log.DataflowBlockCreated(this, dataflowBlockOptions);
        }
    }