14 implementations of ReserveMessage
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
178bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target) 687bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target) 1633public bool ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\BatchBlock.cs (1)
164bool ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target)
Blocks\BatchedJoinBlock.cs (2)
183bool ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ReserveMessage( 440bool ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ReserveMessage(
Blocks\BroadcastBlock.cs (1)
427bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\BufferBlock.cs (1)
210bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\JoinBlock.cs (2)
175bool ISourceBlock<Tuple<T1, T2>>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target) 405bool ISourceBlock<Tuple<T1, T2, T3>>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target)
Blocks\TransformBlock.cs (1)
383bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\TransformManyBlock.cs (1)
589bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\WriteOnceBlock.cs (1)
408bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Internal\TargetRegistry.cs (1)
334bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
7 references to ReserveMessage
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (2)
183return _source.ReserveMessage(messageHeader, this); 1635return _source.ReserveMessage(messageHeader, target);
Blocks\BatchBlock.cs (2)
793if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch)) 811if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch))
Blocks\JoinBlock.cs (1)
632if (next.Key.ReserveMessage(next.Value, this))
Internal\Common.cs (1)
520if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, target))
Internal\TargetRegistry.cs (1)
336return _owningSource.ReserveMessage(messageHeader, this);