2 references to QueuedMap
System.Threading.Tasks.Dataflow (2)
Blocks\JoinBlock.cs (1)
503
internal readonly QueuedMap<ISourceBlock<T>, DataflowMessageHeader> PostponedMessages = new
QueuedMap
<ISourceBlock<T>, DataflowMessageHeader>();
Internal\Common.cs (1)
643
new
QueuedMap
<ISourceBlock<TInput>, DataflowMessageHeader>();