···

       
33
       
33
       
 
       
		select {

     

       
34
       
34
       
 
       
		case <-ctx.Done():

     

       
35
       
35
       
 
       
			slog.Info("stopping cursor checkpointer", "err", ctx.Err())

     

       
36
       
36
       
-
       
			cs.PersistFirehoseCursor() // one final save

     

       
37
       
36
       
 
       
			return

     

       
38
       
37
       
 
       
		case <-t.C:

     

       
39
       
38
       
 
       
		}