INNER CODE UNIT · Go

s

unitedrhino/things · sdk/protocol/coreProtocol.go:177

			s := services.MustNewServer(p.rpcConf, func(grpcServer *grpc.Server) {
				for _, f := range p.rpcRegisters {
					f(grpcServer)
				}
				if p.rpcConf.Mode == service.DevMode || p.rpcConf.Mode == service.TestMode {
					reflection.Register(grpcServer)
				}
			})
			defer s.Stop()
			p.cancels = append(p.cancels, s.Stop)
			s.AddUnaryInterceptors(interceptors.Ctxs, interceptors.Error)
			p.rpcServer = s
			s.Start()
		})
	}
	return nil
}
func (p *CoreProtocol) AddStopHandle(h ...func()) {

View source record →