From f58b1c1f4cc6c65a56a4808f7027c1f8ad32d7bd Mon Sep 17 00:00:00 2001 From: Ulf Bjorkengren Date: Wed, 8 Jan 2025 09:43:42 +0100 Subject: [PATCH] gRPC refactoring update Signed-off-by: Ulf Bjorkengren --- server/vissv2server/grpcMgr/testprocess/gRPCClient.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/server/vissv2server/grpcMgr/testprocess/gRPCClient.go b/server/vissv2server/grpcMgr/testprocess/gRPCClient.go index a6b685e2..2b09b8f8 100644 --- a/server/vissv2server/grpcMgr/testprocess/gRPCClient.go +++ b/server/vissv2server/grpcMgr/testprocess/gRPCClient.go @@ -14,7 +14,6 @@ import ( "time" ) -var grpcCompr utils.Compression var commandStr []string func InitCommandStr() { @@ -46,12 +45,12 @@ func gRPCThread(done chan interface{}, wg *sync.WaitGroup, id int) error { } // setup grpc stream - client := pb.NewVISSv2Client(c) + client := pb.NewVISSClient(c) ctx, cancel := context.WithCancel(context.Background()) defer cancel() vssRequest := commandStr[0] - pbRequest := utils.SubscribeRequestJsonToPb(vssRequest, grpcCompr) + pbRequest := utils.SubscribeRequestJsonToPb(vssRequest) stream, err := client.SubscribeRequest(ctx, pbRequest) working := true