ConsumeMessage() [1/2]

T ISourceBlock< T >. System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.ConsumeMessage ( DataflowMessageHeader messageHeader, ITargetBlock< T > target, out bool messageConsumed )

inlineprivate

Definition at line 315 of file WriteOnceBlock.cs.

    {
        if (!messageHeader.IsValid)
        {
            throw new ArgumentException(System.SR.Argument_InvalidMessageHeader, "messageHeader");
        }
        if (target == null)
        {
            throw new ArgumentNullException("target");
        }
        if (_header.Id == messageHeader.Id)
        {
            messageConsumed = true;
            return CloneItem(_value);
        }
        messageConsumed = false;
        return default(T);
    }

References System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._header, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._value, System.SR.Argument_InvalidMessageHeader, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.CloneItem(), and System.Threading.Tasks.Dataflow.DataflowMessageHeader.Id.