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

stream: make ping method private

Browse Source
This commit is contained in:
c9s 2022-01-11 01:24:34 +08:00
parent a66070d286
commit e12178b51a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/types/stream.go
View File

@ -233,7 +233,7 @@ func (s *StandardStream) Read(ctx context.Context, conn *websocket.Conn, cancel
} }
} }
func (s *StandardStream) Ping(ctx context.Context, conn *websocket.Conn, cancel context.CancelFunc, interval time.Duration) { func (s *StandardStream) ping(ctx context.Context, conn *websocket.Conn, cancel context.CancelFunc, interval time.Duration) {
defer func() { defer func() {
cancel() cancel()
log.Debug("ping worker stopped") log.Debug("ping worker stopped")
@ -325,7 +325,7 @@ func (s *StandardStream) DialAndConnect(ctx context.Context) error {
s.EmitConnect() s.EmitConnect()
go s.Read(connCtx, conn, connCancel) go s.Read(connCtx, conn, connCancel)
go s.Ping(connCtx, conn, connCancel, pingInterval) go s.ping(connCtx, conn, connCancel, pingInterval)
return nil return nil
} }