16 implementations of OfferMessage
System.Threading.Tasks.Dataflow (16)
Base\DataflowBlock.cs (6)
130DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1146DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1460DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1547public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2099public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 2607DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\ActionBlock.cs (1)
281DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\BatchBlock.cs (1)
149DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BatchedJoinBlock.cs (1)
564public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BroadcastBlock.cs (1)
160DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BufferBlock.cs (1)
88DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\JoinBlock.cs (1)
814DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\TransformBlock.cs (1)
365DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\TransformManyBlock.cs (1)
574DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\WriteOnceBlock.cs (1)
335DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Internal\TargetRegistry.cs (1)
321DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
12 references to OfferMessage
System.Threading.Tasks.Dataflow (12)
Base\DataflowBlock.cs (5)
144return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); 241return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false) == DataflowMessageStatus.Accepted; 300switch (target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false)) 569switch (_target.OfferMessage( 1549return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept);
Blocks\BroadcastBlock.cs (2)
687DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(_nextMessageId), currentMessage!, _owningSource, consumeToAccept: useCloning); 792switch (target.OfferMessage(header, message, _owningSource, consumeToAccept: useCloning))
Blocks\WriteOnceBlock.cs (3)
321target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 427target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 463target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning);
Internal\SourceCore.cs (1)
671DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false);
Internal\TargetRegistry.cs (1)
324return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept);