_nextMessageId

9 references to _nextMessageId

System.Threading.Tasks.Dataflow (9)

Internal\SourceCore.cs (9)

184if (messageHeader.Id != _nextMessageId.Value || 194_nextMessageId.Value++; 227if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 254if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 291_nextMessageId.Value++; 344_nextMessageId.Value++; 562header = new DataflowMessageHeader(_nextMessageId.Value); 619if (_nextMessageId.Value != header.Id || 624_nextMessageId.Value++;