diff --git a/src/dataqueue/queue.cc b/src/dataqueue/queue.cc index e6b7a4893b4bf5..c3de4eb570beab 100644 --- a/src/dataqueue/queue.cc +++ b/src/dataqueue/queue.cc @@ -176,10 +176,10 @@ class DataQueueImpl final : public DataQueue, void NotifyBackpressure(size_t amount) { if (idempotent_) return; - for (auto listener : backpressure_listeners_) listener->EntryRead(amount); + for (auto& listener : backpressure_listeners_) listener->EntryRead(amount); } - bool HasBackpressureListeners() const { + bool HasBackpressureListeners() const noexcept { return !backpressure_listeners_.empty(); }