14 implementations of ReleaseReservation
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (3)
187
void ISourceBlock<T>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
704
void ISourceBlock<TOutput>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
1696
public void
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\BatchBlock.cs (1)
170
void ISourceBlock<T[]>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T[]> target)
Blocks\BatchedJoinBlock.cs (2)
190
void ISourceBlock<Tuple<IList<T1>, IList<T2>>>.
ReleaseReservation
(
447
void ISourceBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>>.
ReleaseReservation
(
Blocks\BroadcastBlock.cs (1)
433
void ISourceBlock<T>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\BufferBlock.cs (1)
216
void ISourceBlock<T>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Blocks\JoinBlock.cs (2)
181
void ISourceBlock<Tuple<T1, T2>>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2>> target)
411
void ISourceBlock<Tuple<T1, T2, T3>>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<Tuple<T1, T2, T3>> target)
Blocks\TransformBlock.cs (1)
389
void ISourceBlock<TOutput>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\TransformManyBlock.cs (1)
595
void ISourceBlock<TOutput>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<TOutput> target)
Blocks\WriteOnceBlock.cs (1)
421
void ISourceBlock<T>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
Internal\TargetRegistry.cs (1)
340
void ISourceBlock<T>.
ReleaseReservation
(DataflowMessageHeader messageHeader, ITargetBlock<T> target)
6 references to ReleaseReservation
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (2)
192
_source.
ReleaseReservation
(messageHeader, this);
1698
_source.
ReleaseReservation
(messageHeader, target);
Blocks\BatchBlock.cs (1)
1100
try { source.
ReleaseReservation
(message.Key, _owningBatch); }
Blocks\JoinBlock.cs (1)
771
try { _nonGreedy.ReservedMessage.Key.
ReleaseReservation
(_nonGreedy.ReservedMessage.Value, this); }
Internal\Common.cs (1)
522
sourceAndMessage.Key.
ReleaseReservation
(sourceAndMessage.Value, target);
Internal\TargetRegistry.cs (1)
342
_owningSource.
ReleaseReservation
(messageHeader, this);