Skip to content

Commit

Permalink
gRPC refactoring update
Browse files Browse the repository at this point in the history
Signed-off-by: Ulf Bjorkengren <[email protected]>
  • Loading branch information
UlfBj committed Jan 8, 2025
1 parent 96fb4f8 commit f58b1c1
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions server/vissv2server/grpcMgr/testprocess/gRPCClient.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ import (
"time"
)

var grpcCompr utils.Compression
var commandStr []string

func InitCommandStr() {
Expand Down Expand Up @@ -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

Expand Down

0 comments on commit f58b1c1

Please sign in to comment.