Delete heartbeat before stopAndWait

OffchainLabs · May 16, 2024 · f18419b · f18419b
1 parent 4591061
commit f18419b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pubsub/consumer.go b/pubsub/consumer.go
@@ -108,8 +108,8 @@ func (c *Consumer[Request, Response]) listenForInterrupt() {
 }
 
 func (c *Consumer[Request, Response]) StopAndWait() {
-	c.StopWaiter.StopAndWait()
 	c.deleteHeartBeat(c.GetContext())
+	c.StopWaiter.StopAndWait()
 }
 
 func heartBeatKey(id string) string {