return on send err

castai · Sep 27, 2024 · bf24e48 · bf24e48
1 parent 0cff2f4
commit bf24e48
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/proxy/client.go b/internal/proxy/client.go
@@ -182,7 +182,8 @@ func (c *Client) run(ctx context.Context) error {
 		case req := <-sendCh:
 			c.log.Printf("Sending message to stream")
 			if err := stream.Send(req); err != nil {
-				c.log.WithError(err).Warn("failed to send keep alive")
+				c.log.WithError(err).Warn("failed to send message to stream")
+				return fmt.Errorf("failed to send message to stream: %w", err)
 			}
 		case <-time.After(time.Duration(c.keepAlive.Load())):
 			if !c.isAlive() {