close connections explicitly

open-telemetry · Feb 6, 2024 · 8d04fca · 8d04fca
1 parent 61d7baf
commit 8d04fca
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/client/wsclient.go b/client/wsclient.go
@@ -257,6 +257,10 @@ func (c *wsClient) runOneCycle(ctx context.Context) {
 		// sender will send close message to initiate the close handshake
 		if err := c.sender.StoppingErr(); err != nil {
 			c.common.Logger.Debugf("Error stopping the sender: %v", err)
+
+			// Close the connection to stop the receiver.
+			_ = c.conn.Close()
+			<-r.IsStopped()
 			break
 		}