Skip to content

Commit 6f649a8

Browse files
committed
Avoid calling potentially nit func
1 parent 6f83f88 commit 6f649a8

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

storage/gcp/antispam/gcp.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -380,7 +380,9 @@ func (f *follower) Follow(ctx context.Context, lr tessera.LogReader) {
380380
if err != errOutOfSync {
381381
slog.ErrorContext(ctx, "Failed to commit antispam population tx", slog.Any("error", err))
382382
}
383-
stop()
383+
if stop != nil {
384+
stop()
385+
}
384386
next = nil
385387
streamDone = true
386388
continue

0 commit comments

Comments
 (0)