From a66070d286ba8511a3c44fb9d43fe14bebeb05b2 Mon Sep 17 00:00:00 2001 From: c9s Date: Tue, 11 Jan 2022 01:24:01 +0800 Subject: [PATCH] stream: make reconnector private --- pkg/types/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/types/stream.go b/pkg/types/stream.go index e7bef30c0..81c0e594e 100644 --- a/pkg/types/stream.go +++ b/pkg/types/stream.go @@ -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 {