OfferMessage() [1/2]

DataflowMessageStatus ITargetBlock< T >. System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.OfferMessage ( DataflowMessageHeader messageHeader, T messageValue, ISourceBlock< T > source, bool consumeToAccept )

inlineprivate

Definition at line 275 of file WriteOnceBlock.cs.

    {
        if (!messageHeader.IsValid)
        {
            throw new ArgumentException(System.SR.Argument_InvalidMessageHeader, "messageHeader");
        }
        if (source == null && consumeToAccept)
        {
            throw new ArgumentException(System.SR.Argument_CantConsumeFromANullSource, "consumeToAccept");
        }
        bool flag = false;
        lock (ValueLock)
        {
            if (_decliningPermanently)
            {
                return DataflowMessageStatus.DecliningPermanently;
            }
            if (consumeToAccept)
            {
                messageValue = source.ConsumeMessage(messageHeader, this, out var messageConsumed);
                if (!messageConsumed)
                {
                    return DataflowMessageStatus.NotAvailable;
                }
            }
            _header = Common.SingleMessageHeader;
            _value = messageValue;
            _decliningPermanently = true;
            if (!_completionReserved)
            {
                flag = (_completionReserved = true);
            }
        }
        if (flag)
        {
            CompleteBlockAsync(null);
        }
        return DataflowMessageStatus.Accepted;
    }

References System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._completionReserved, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._decliningPermanently, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._header, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._value, System.SR.Argument_CantConsumeFromANullSource, System.SR.Argument_InvalidMessageHeader, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.CompleteBlockAsync(), System.Threading.Tasks.Dataflow.Internal.Common.SingleMessageHeader, System.source, and System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.ValueLock.