3 instantiations of QueuedMap
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (1)
294PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>(batchSize);
Blocks\JoinBlock.cs (1)
503internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>();
Internal\Common.cs (1)
643new QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>();
13 references to QueuedMap
System.Threading.Tasks.Dataflow (13)
Blocks\ActionBlock.cs (1)
354public QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages
Blocks\BatchBlock.cs (5)
232public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _targetDebuggingInformation.PostponedMessages; } } 275internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages; 760QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 878QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 1184public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _target._nonGreedyState?.PostponedMessages; } }
Blocks\BufferBlock.cs (1)
454public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages
Blocks\JoinBlock.cs (1)
503internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>();
Blocks\TransformBlock.cs (1)
432public QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages { get { return _targetDebuggingInformation.PostponedMessages; } }
Blocks\TransformManyBlock.cs (1)
638public QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages { get { return _targetDebuggingInformation.PostponedMessages; } }
Internal\Common.cs (2)
498QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponedMessages, 642internal readonly QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader> PostponedMessages =
Internal\TargetCore.cs (1)
859internal QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages