From 6f0dec9e931c658218e0403cc972af66865c39b0 Mon Sep 17 00:00:00 2001 From: yyasha Date: Wed, 5 Jun 2024 10:38:16 +0300 Subject: [PATCH] fix ws closing --- bybit_websocket.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/bybit_websocket.go b/bybit_websocket.go index 8f8355a..e03ae9c 100644 --- a/bybit_websocket.go +++ b/bybit_websocket.go @@ -121,6 +121,10 @@ func (b *WebSocket) Connect(args []string) error { eg.Go(b.Ping) eg.Go(b.handleIncomingMessages) + if err := b.sendSubscription(args); err != nil { + return fmt.Errorf("failed to send subscription: %w", err) + } + if err := eg.Wait(); err != nil { b.Disconnect() return fmt.Errorf("failed to handle message: %w", err)