3 instantiations of QueuedMap
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (1)
291PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>(batchSize);
Blocks\JoinBlock.cs (1)
491internal 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)
345public QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages
Blocks\BatchBlock.cs (5)
229public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _targetDebuggingInformation.PostponedMessages; } } 272internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages; 757QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 875QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 1181public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _target._nonGreedyState?.PostponedMessages; } }
Blocks\BufferBlock.cs (1)
448public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages
Blocks\JoinBlock.cs (1)
491internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>();
Blocks\TransformBlock.cs (1)
426public QueuedMap<ISourceBlock<TInput>, DataflowMessageHeader>? PostponedMessages { get { return _targetDebuggingInformation.PostponedMessages; } }
Blocks\TransformManyBlock.cs (1)
635public 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