From cdb51bac8647e111a681dd88ae0a33bf4a0834fb Mon Sep 17 00:00:00 2001 From: Atridad Lahiji Date: Thu, 2 May 2024 14:55:28 -0600 Subject: [PATCH] Fixed edge case where a message is being processed while a client is disconnecting. --- lib/sse.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sse.go b/lib/sse.go index 5b145c6..aae175b 100644 --- a/lib/sse.go +++ b/lib/sse.go @@ -100,7 +100,7 @@ func HandleIncomingMessages(c echo.Context, pubsub pubsub.PubSubMessage, client msg, err := pubsub.ReceiveMessage(c.Request().Context()) if err != nil { log.Printf("Failed to receive message: %v", err) - continue + return } data := fmt.Sprintf("data: %s\n\n", msg.Payload)