diff --git a/client/websocket.go b/client/websocket.go index 58ecbf45dd1..906787d3013 100644 --- a/client/websocket.go +++ b/client/websocket.go @@ -45,7 +45,7 @@ func (p *Client) Websocket(query string, options ...Option) *Subscription { // Grab a single response from a websocket based query func (p *Client) WebsocketOnce(query string, resp interface{}, options ...Option) error { - sock := p.Websocket(query) + sock := p.Websocket(query, options...) defer sock.Close() return sock.Next(&resp) }