3 writes to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (3)
191_nextMessageReservedFor = null; 229_nextMessageReservedFor = target; 257_nextMessageReservedFor = null;
11 references to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (11)
Internal\SourceCore.cs (11)
170if (_nextMessageReservedFor != target && 171_nextMessageReservedFor != null) 222if (_nextMessageReservedFor == null) 249if (_nextMessageReservedFor != target) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 283if (_nextMessageReservedFor == null) 330if (_nextMessageReservedFor == null) 541if (_nextMessageReservedFor != null) 688else if (_nextMessageReservedFor != null) 893_nextMessageReservedFor == null) // no pending reservation 907_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null, 1016internal ITargetBlock<TOutput>? NextMessageReservedFor { get { return _source._nextMessageReservedFor; } }