From 886e69009c15654ec6f5266a949efd034d89d44d Mon Sep 17 00:00:00 2001 From: "FLEXERA\\NTaylor-Barnett" Date: Wed, 16 Mar 2022 16:36:48 +1100 Subject: [PATCH] changes anypb.Any to emptypb.Empty (thanks @danw for the fix) --- proxy/handler.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/proxy/handler.go b/proxy/handler.go index 95799a0..c0460ea 100644 --- a/proxy/handler.go +++ b/proxy/handler.go @@ -11,6 +11,7 @@ import ( "google.golang.org/grpc/codes" "google.golang.org/grpc/status" "google.golang.org/protobuf/types/known/anypb" + "google.golang.org/protobuf/types/known/emptypb" ) var ( @@ -112,7 +113,7 @@ func (s *handler) handler(srv interface{}, serverStream grpc.ServerStream) error func (s *handler) forwardClientToServer(src grpc.ClientStream, dst grpc.ServerStream) chan error { ret := make(chan error, 1) go func() { - f := &anypb.Any{} + f := &emptypb.Empty{} for i := 0; ; i++ { if err := src.RecvMsg(f); err != nil { ret <- err // this can be io.EOF which is happy case