add consumeUntilDrained API to NotificationQueue::Consumer