Skip to content

Commit 6e5578a

Browse files
committed
Add comment for offset lag calculation
1 parent e1a31e0 commit 6e5578a

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

deps/rabbitmq_stream/src/rabbit_stream_utils.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -349,6 +349,7 @@ consumer_offset(ConsumerOffsetFromCounter, _, _) ->
349349
MessageConsumed :: non_neg_integer(),
350350
LastListenerOffset :: integer() | undefined) -> integer().
351351
offset_lag(-1, _, _, _) ->
352+
%% -1 is for an empty stream, so no lag
352353
0;
353354
offset_lag(_, 0, 0, LastListenerOffset) when LastListenerOffset > 0 ->
354355
%% consumer waiting for messages at the end of the stream, most likely

0 commit comments

Comments
 (0)