Function ConditionalStreamMiddleware

controller/rpc/middleware.go:222–242

(s *Service)

}

func ConditionalStreamMiddleware(s *Service) grpc.StreamServerInterceptor {
	return func(
		srv interface{},
		ss grpc.ServerStream,
		info *grpc.StreamServerInfo,
		handler grpc.StreamHandler,
	) error {
		var interceptors []grpc.StreamServerInterceptor

		interceptors = append(interceptors, LoggingStreamInterceptor(s))

		interceptors = append(interceptors, validateApiKeyStreamMiddleware(s))

		if backendMethods[info.FullMethod] {
			interceptors = append(interceptors, CheckBackendStreamMiddleware(s))
		}

		chained := grpcmiddleware.ChainStreamServer(interceptors...)
		return chained(srv, ss, info, handler)
	}
}