14 implementations of ReleaseReservation
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
169void ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T> target) 680void ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target) 1594public void ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\BatchBlock.cs (1)
167void ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target)
Blocks\BatchedJoinBlock.cs (2)
187void ISourceBlock<Tuple<IList<T1>, IList<T2>>>.ReleaseReservation( 441void ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.ReleaseReservation(
Blocks\BroadcastBlock.cs (1)
427void ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\BufferBlock.cs (1)
210void ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\JoinBlock.cs (2)
175void ISourceBlock<Tuple<T1, T2>>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target) 399void ISourceBlock<Tuple<T1, T2, T3>>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target)
Blocks\TransformBlock.cs (1)
383void ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\TransformManyBlock.cs (1)
592void ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\WriteOnceBlock.cs (1)
409void ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Internal\TargetRegistry.cs (1)
340void ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
6 references to ReleaseReservation
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (2)
174_source.ReleaseReservation(messageHeader, this); 1596_source.ReleaseReservation(messageHeader, target);
Blocks\BatchBlock.cs (1)
1097try { source.ReleaseReservation(message.Key, _owningBatch); }
Blocks\JoinBlock.cs (1)
759try { _nonGreedy.ReservedMessage.Key.ReleaseReservation(_nonGreedy.ReservedMessage.Value, this); }
Internal\Common.cs (1)
522sourceAndMessage.Key.ReleaseReservation(sourceAndMessage.Value, target);
Internal\TargetRegistry.cs (1)
342_owningSource.ReleaseReservation(messageHeader, this);