16 implementations of OfferMessage
System.Threading.Tasks.Dataflow (16)
Base\DataflowBlock.cs (6)
148DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1179DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1493DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1592public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2180public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 2697DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\ActionBlock.cs (1)
290DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\BatchBlock.cs (1)
152DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BatchedJoinBlock.cs (1)
570public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BroadcastBlock.cs (1)
166DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\BufferBlock.cs (1)
91DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\JoinBlock.cs (1)
826DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
Blocks\TransformBlock.cs (1)
371DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\TransformManyBlock.cs (1)
577DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)
Blocks\WriteOnceBlock.cs (1)
347DataflowMessageStatus 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)
162return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); 262return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false) == DataflowMessageStatus.Accepted; 324switch (target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false)) 593switch (_target.OfferMessage( 1594return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept);
Blocks\BroadcastBlock.cs (2)
693DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(_nextMessageId), currentMessage!, _owningSource, consumeToAccept: useCloning); 798switch (target.OfferMessage(header, message, _owningSource, consumeToAccept: useCloning))
Blocks\WriteOnceBlock.cs (3)
333target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 439target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 475target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning);
Internal\SourceCore.cs (1)
677DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false);
Internal\TargetRegistry.cs (1)
324return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept);