lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 17:13:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

okex: remove private dial method

Browse Source
This commit is contained in:
c9s 2021-05-27 15:16:01 +08:00
parent f4f4304df6
commit 03431da00c
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/exchange/okex/stream.go
View File

@ -113,16 +113,6 @@ func (s *Stream) Reconnector(ctx context.Context) {
}
}
func (s *Stream) dial() (*websocket.Conn, error) {
var url string
if s.publicOnly {
url = okexapi.PublicWebSocketURL
} else {
url = okexapi.PrivateWebSocketURL
}
return s.StandardStream.Dial(url)
}
func (s *Stream) connect(ctx context.Context) error {
// should only start one connection one time, so we lock the mutex
s.connLock.Lock()
@ -137,7 +127,14 @@ func (s *Stream) connect(ctx context.Context) error {
}
// when in public mode, the listen key is an empty string
conn, err := s.dial()
var url string
if s.publicOnly {
url = okexapi.PublicWebSocketURL
} else {
url = okexapi.PrivateWebSocketURL
}
conn, err := s.StandardStream.Dial(url)
if err != nil {
s.connCancel()
s.connLock.Unlock()