From e0603f741f9efeb3917ee049bf4b037c2f198d74 Mon Sep 17 00:00:00 2001 From: Xavier Michelon Date: Fri, 14 Oct 2022 16:51:12 +0200 Subject: [PATCH] Other: fix gRPC event stream that was broken during GODT-1936 --- internal/frontend/grpc/service.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/frontend/grpc/service.go b/internal/frontend/grpc/service.go index 0312f18e..e082b6c1 100644 --- a/internal/frontend/grpc/service.go +++ b/internal/frontend/grpc/service.go @@ -504,10 +504,10 @@ func (s *Service) validateUnaryServerToken( // validateStreamServerToken check the server token for every gRPC stream request. func (s *Service) validateStreamServerToken( - _ interface{}, + srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, - _ grpc.StreamHandler, + handler grpc.StreamHandler, ) error { logEntry := s.log.WithField("FullMethod", info.FullMethod) @@ -516,5 +516,5 @@ func (s *Service) validateStreamServerToken( return err } - return nil + return handler(srv, ss) }