OfferToTargets()

List< Exception > System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.OfferToTargets ( )

inlineprivate

Definition at line 374 of file WriteOnceBlock.cs.

    {
        List<Exception> list = null;
        if (HasValue)
        {
            TargetRegistry<T>.LinkedTargetInfo linkedTargetInfo = _targetRegistry.FirstTargetNode;
            while (linkedTargetInfo != null)
            {
                TargetRegistry<T>.LinkedTargetInfo next = linkedTargetInfo.Next;
                ITargetBlock<T> target = linkedTargetInfo.Target;
                try
                {
                    bool consumeToAccept = _cloningFunction != null;
                    target.OfferMessage(_header, _value, this, consumeToAccept);
                }
                catch (Exception ex)
                {
                    Common.StoreDataflowMessageValueIntoExceptionData(ex, _value);
                    Common.AddException(ref list, ex);
                }
                linkedTargetInfo = next;
            }
        }
        return list;
    }

References System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._cloningFunction, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._header, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._targetRegistry, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._value, System.Threading.Tasks.Dataflow.Internal.Common.AddException(), System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.HasValue, and System.list.

Referenced by System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.OfferToTargetsAndCompleteBlock().