14 implementations of ReserveMessage
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
160bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target) 663bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target) 1588public bool ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\BatchBlock.cs (1)
161bool ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target)
Blocks\BatchedJoinBlock.cs (2)
180bool ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ReserveMessage( 434bool ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ReserveMessage(
Blocks\BroadcastBlock.cs (1)
421bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\BufferBlock.cs (1)
204bool ISourceBlock<T>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\JoinBlock.cs (2)
169bool ISourceBlock<Tuple<T1, T2>>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target) 393bool ISourceBlock<Tuple<T1, T2, T3>>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target)
Blocks\TransformBlock.cs (1)
377bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\TransformManyBlock.cs (1)
586bool ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\WriteOnceBlock.cs (1)
396bool 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)
165return _source.ReserveMessage(messageHeader, this); 1590return _source.ReserveMessage(messageHeader, target);
Blocks\BatchBlock.cs (2)
790if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch)) 808if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch))
Blocks\JoinBlock.cs (1)
620if (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);