1 reference to ConsumeMessagesLoopCore
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
260
new Task(static state => ((BroadcastBlock<T>)state!).
ConsumeMessagesLoopCore
(), this,