3 writes to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (3)
197_nextMessageReservedFor = null; 235_nextMessageReservedFor = target; 263_nextMessageReservedFor = null;
11 references to _nextMessageReservedFor
System.Threading.Tasks.Dataflow (11)
Internal\SourceCore.cs (11)
176if (_nextMessageReservedFor != target && 177_nextMessageReservedFor != null) 228if (_nextMessageReservedFor == null) 255if (_nextMessageReservedFor != target) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 289if (_nextMessageReservedFor == null) 336if (_nextMessageReservedFor == null) 547if (_nextMessageReservedFor != null) 694else if (_nextMessageReservedFor != null) 899_nextMessageReservedFor == null) // no pending reservation 913_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null, 1022internal ITargetBlock<TOutput>? NextMessageReservedFor { get { return _source._nextMessageReservedFor; } }