1 write to _messages
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
124
_messages
= (dataflowBlockOptions.MaxDegreeOfParallelism == 1) ?
14 references to _messages
System.Threading.Tasks.Dataflow (14)
Internal\TargetCore.cs (14)
79
private object IncomingLock { get { return
_messages
; } }
162
while (
_messages
.TryDequeue(out dummy)) ;
220
_messages
.Enqueue(new KeyValuePair<TInput, long>(messageValue!, messageId));
244
internal int InputCount { get { return
_messages
.GetCountSafe(IncomingLock); } }
359
!
_messages
.IsEmpty ||
380
_messages
.Count + (_boundingState != null ? _boundingState.PostponedMessages.Count : 0));
429
_messages
.Enqueue(transferMessageWithId);
580
if (
_messages
.TryDequeue(out messageWithId))
635
if (!forPostponementTransfer &&
_messages
.TryDequeue(out result))
717
bool noMoreMessages = _decliningPermanently &&
_messages
.IsEmpty;
730
Debug.Assert((_decliningPermanently &&
_messages
.IsEmpty) || CanceledOrFaulted, "There must be no more messages.");
772
IProducerConsumerQueue<KeyValuePair<TInput, long>> messages =
_messages
;
854
internal int InputCount { get { return _target.
_messages
.Count; } }
856
internal IEnumerable<TInput> InputQueue { get { return _target.
_messages
.Select(static kvp => kvp.Key).ToList(); } }