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)