Method WaitForReaderDrainAsync
WaitForReaderDrainAsync()
Waits for the user-side reader to exit so buffered messages can be drained on dispose. No-op when the reader was never marked active or when ConsumerDrainOnDisposeTimeout is unset.
protected virtual ValueTask WaitForReaderDrainAsync()