From 3021e4248579a7682a4c6fa2db049bd153847680 Mon Sep 17 00:00:00 2001 From: Ye Sijun Date: Fri, 7 Mar 2025 13:45:39 +0900 Subject: [PATCH] okx: move WsResponseMultiplexer to setDefaults Signed-off-by: Ye Sijun --- exchanges/okx/okx_wrapper.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/exchanges/okx/okx_wrapper.go b/exchanges/okx/okx_wrapper.go index 2bcd2cc3811..81053e25d27 100644 --- a/exchanges/okx/okx_wrapper.go +++ b/exchanges/okx/okx_wrapper.go @@ -181,6 +181,14 @@ func (ok *Okx) SetDefaults() { ok.WebsocketResponseMaxLimit = websocketResponseMaxLimit ok.WebsocketResponseCheckTimeout = websocketResponseMaxLimit ok.WebsocketOrderbookBufferLimit = exchange.DefaultWebsocketOrderbookBufferLimit + + ok.WsResponseMultiplexer = wsRequestDataChannelsMultiplexer{ + WsResponseChannelsMap: make(map[string]*wsRequestInfo), + Register: make(chan *wsRequestInfo), + Unregister: make(chan string), + Message: make(chan *wsIncomingData), + shutdown: make(chan bool), + } } // Setup takes in the supplied exchange configuration details and sets params @@ -196,14 +204,6 @@ func (ok *Okx) Setup(exch *config.Exchange) error { return err } - ok.WsResponseMultiplexer = wsRequestDataChannelsMultiplexer{ - WsResponseChannelsMap: make(map[string]*wsRequestInfo), - Register: make(chan *wsRequestInfo), - Unregister: make(chan string), - Message: make(chan *wsIncomingData), - shutdown: make(chan bool), - } - wsRunningEndpoint, err := ok.API.Endpoints.GetURL(exchange.WebsocketSpot) if err != nil { return err