diff --git a/pkg/gordio/nexus/websocket.go b/pkg/gordio/nexus/websocket.go index bf2e982..efcc331 100644 --- a/pkg/gordio/nexus/websocket.go +++ b/pkg/gordio/nexus/websocket.go @@ -115,7 +115,7 @@ func (conn *wsConn) readPump(ctx context.Context, reg Registry, c Client) { break } - go c.HandleMessage(ctx, message) + go c.HandleMessage(context.WithoutCancel(ctx), message) } }