d0zingcat/gocryptotrader
1
0
Fork 0
mirror of https://github.com/d0zingcat/gocryptotrader.git synced 2026-05-13 15:09:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

okx: Move WsResponseMultiplexer to SetDefaults (#1829)

Browse Source 
Signed-off-by: Ye Sijun <junnplus@gmail.com>
This commit is contained in:
Jun
2025-03-11 11:37:17 +09:00
committed by GitHub
parent 568ed3021e
commit 5c21e974ee
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
exchanges/okx/okx_wrapper.go
View File

@@ -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