1 reference to ConsumeAndStoreOneMessageIfAvailable
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
295
i < maxMessagesPerTask &&
ConsumeAndStoreOneMessageIfAvailable
();