| 77 | } |
| 78 | |
| 79 | func (a *App) AddGRPCServerStreamInterceptors(interceptors ...grpc.StreamServerInterceptor) { |
| 80 | if len(interceptors) == 0 { |
| 81 | a.container.Logger.Debug("no stream interceptors provided") |
| 82 | return |
| 83 | } |
| 84 | |
| 85 | a.container.Logger.Debugf("adding %d stream interceptors", len(interceptors)) |
| 86 | a.grpcServer.streamInterceptors = append(a.grpcServer.streamInterceptors, interceptors...) |
| 87 | } |
| 88 | |
| 89 | func newGRPCServer(c *container.Container, port int, cfg config.Config) (*grpcServer, error) { |
| 90 | if port <= 0 || port > 65535 { |