We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ca1bfb commit 918abb9Copy full SHA for 918abb9
src/dataqueue/queue.cc
@@ -176,10 +176,10 @@ class DataQueueImpl final : public DataQueue,
176
177
void NotifyBackpressure(size_t amount) {
178
if (idempotent_) return;
179
- for (auto listener : backpressure_listeners_) listener->EntryRead(amount);
+ for (auto& listener : backpressure_listeners_) listener->EntryRead(amount);
180
}
181
182
- bool HasBackpressureListeners() const {
+ bool HasBackpressureListeners() const noexcept {
183
return !backpressure_listeners_.empty();
184
185
0 commit comments