x

Author: chenquan

zrpc/internal/rpcpubserver.go

@@ -58,7 +58,7 @@ func (s keepAliveServer) Start(fn RegisterFn) error {
 		ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
 		defer cancel()
 
-		ticker := time.NewTicker(time.Second)
+		ticker := time.NewTicker(time.Second / 2)
 		defer ticker.Stop()
 
 		for {

zrpc/internal/rpcpubserver_test.go

@@ -19,9 +19,8 @@ func TestNewRpcPubServer(t *testing.T) {
 	}, "")
 	assert.NoError(t, err)
 	health.MarkReady()
-	assert.NotPanics(t, func() {
+	assert.Panics(t, func() {
 		s.Start(func(server *grpc.Server) {
-
 		})
 	})
 }