3 writes to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (3)
1054
_nextMessageReservedFor
= null;
1088
_nextMessageReservedFor
= target;
1117
_nextMessageReservedFor
= null;
5 references to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (5)
Blocks\BroadcastBlock.cs (5)
724
if (
_nextMessageReservedFor
== null && _messages.Count > 0)
1052
if (
_nextMessageReservedFor
== target)
1081
if (
_nextMessageReservedFor
== null)
1108
if (
_nextMessageReservedFor
!= target) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget);
1220
public ITargetBlock<TOutput>? NextMessageReservedFor { get { return _source.
_nextMessageReservedFor
; } }