mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-26 00:35:15 +00:00
stream: make reconnector private
This commit is contained in:
parent
16ec856a4e
commit
a66070d286
|
@ -284,13 +284,13 @@ func (s *StandardStream) Connect(ctx context.Context) error {
|
|||
}
|
||||
|
||||
// start one re-connector goroutine with the base context
|
||||
go s.Reconnector(ctx)
|
||||
go s.reconnector(ctx)
|
||||
|
||||
s.EmitStart()
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *StandardStream) Reconnector(ctx context.Context) {
|
||||
func (s *StandardStream) reconnector(ctx context.Context) {
|
||||
for {
|
||||
select {
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user