From 6a9ebbf453df0d8858f638d625db4b8b4a5dc9ee Mon Sep 17 00:00:00 2001 From: matst80 Date: Sun, 12 Oct 2025 23:19:35 +0200 Subject: [PATCH] =?UTF-8?q?s=C3=A5h?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/actor/grpc_server.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/pkg/actor/grpc_server.go b/pkg/actor/grpc_server.go index 78486c1..f41e773 100644 --- a/pkg/actor/grpc_server.go +++ b/pkg/actor/grpc_server.go @@ -89,14 +89,15 @@ func NewControlServer[V any](addr string, pool GrainPool[V]) (*grpc.Server, erro pool: pool, } - log.Printf("gRPC server listening on %s", addr) - - if err := grpcServer.Serve(lis); err != nil { - log.Fatalf("failed to serve gRPC: %v", err) - } - messages.RegisterControlPlaneServer(grpcServer, server) reflection.Register(grpcServer) + log.Printf("gRPC server listening on %s", addr) + go func() { + if err := grpcServer.Serve(lis); err != nil { + log.Fatalf("failed to serve gRPC: %v", err) + } + }() + return grpcServer, nil }