_nextMessageId

9 references to _nextMessageId

System.Threading.Tasks.Dataflow (9)

Internal\SourceCore.cs (9)

190if (messageHeader.Id != _nextMessageId.Value || 200_nextMessageId.Value++; 233if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 260if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 297_nextMessageId.Value++; 350_nextMessageId.Value++; 568header = new DataflowMessageHeader(_nextMessageId.Value); 625if (_nextMessageId.Value != header.Id || 630_nextMessageId.Value++;