fixed wait on send

castai · Sep 27, 2024 · 55fb63d · 55fb63d
1 parent f1cc03f
commit 55fb63d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/internal/proxy/client.go b/internal/proxy/client.go
@@ -208,13 +208,13 @@ func (c *Client) sendAndReceive(ctx context.Context, stream cloudproxyv1alpha.Cl
 		return err
 	})
 
-	eg.Go(func() error {
+	// send loop is separate because it can block on sending messages.
+	go func() {
 		err := c.send(egctx, stream, sendCh)
 		if err != nil {
-			c.log.Errorf("stopping send loop: %v", err)
+			c.log.Errorf("stopped send loop: %v", err)
 		}
-		return err
-	})
+	}()
 
 	err = eg.Wait()
 	if err != nil {