Skip to content

Commit

Permalink
chore: fix stale comment
Browse files Browse the repository at this point in the history
Signed-off-by: Vigith Maurice <[email protected]>
  • Loading branch information
vigith authored Sep 27, 2024
1 parent d037958 commit d5f50a6
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion pkg/sourcer/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,6 @@ func (fs *Service) AckFn(stream sourcepb.Source_AckFnServer) error {
for {
err := fs.receiveAckRequests(ctx, stream)

// Wait for the goroutines to finish
if err != nil {
if errors.Is(err, io.EOF) {
return nil
Expand Down

0 comments on commit d5f50a6

Please sign in to comment.