3 writes to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (3)
1066
_nextMessageReservedFor
= null;
1100
_nextMessageReservedFor
= target;
1129
_nextMessageReservedFor
= null;
5 references to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (5)
Blocks\BroadcastBlock.cs (5)
730
if (
_nextMessageReservedFor
== null && _messages.Count > 0)
1064
if (
_nextMessageReservedFor
== target)
1093
if (
_nextMessageReservedFor
== null)
1120
if (
_nextMessageReservedFor
!= target) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget);
1232
public ITargetBlock<TOutput>? NextMessageReservedFor { get { return _source.
_nextMessageReservedFor
; } }