Skip to content

Commit aed249e

Browse files
Update cpp/src/streaming/core/fanout.cpp
Co-authored-by: Lawrence Mitchell <[email protected]>
1 parent 0ad1b44 commit aed249e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

cpp/src/streaming/core/fanout.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -288,8 +288,8 @@ struct UnboundedFanout {
288288
return idx != InvalidIdx;
289289
});
290290

291-
auto it = std::ranges::begin(filtered_view); // first valid idx
292-
auto end = std::ranges::end(filtered_view); // end idx
291+
auto it = std::ranges::begin(filtered_view);
292+
auto end = std::ranges::end(filtered_view);
293293

294294
if (it == end) {
295295
// no valid indices, so all send tasks are in an invalid state

0 commit comments

Comments
 (0)