◆ LinkTo() [1/2]

IDisposable System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.LinkTo	(	ITargetBlock< T >	target,
		DataflowLinkOptions	linkOptions )

inline

Definition at line 242 of file WriteOnceBlock.cs.

    {
        if (target == null)
        {
            throw new ArgumentNullException("target");
        }
        if (linkOptions == null)
        {
            throw new ArgumentNullException("linkOptions");
        }
        bool hasValue;
        lock (ValueLock)
        {
            hasValue = HasValue;
            bool completionReserved = _completionReserved;
            if (!hasValue && !completionReserved)
            {
                _targetRegistry.Add(ref target, linkOptions);
                return Common.CreateUnlinker<T>(ValueLock, _targetRegistry, target);
            }
        }
        if (hasValue)
        {
            bool consumeToAccept = _cloningFunction != null;
            target.OfferMessage(_header, _value, this, consumeToAccept);
        }
        if (linkOptions.PropagateCompletion)
        {
            Common.PropagateCompletionOnceCompleted(Completion, target);
        }
        return Disposables.Nop;
    }