Method newRequestHandler

server/server.go:325–333

newRequestHandler returns a context-wrapped Handler to handle requests

(ctx context.Context)

// newRequestHandler returns a context-wrapped Handler to handle requests
func (s *Server) newRequestHandler(ctx context.Context) func(subject string, reply string, req *proxy.Request) {
	return func(subject string, reply string, req *proxy.Request) {
		if !s.ari.Connected() {
			s.sendError(reply, eris.New("ARI connection is down"))
			return
		}
		go s.dispatchRequest(ctx, reply, req)
	}
}

// TODO: see if there is a more programmatic approach to this
// nolint: gocyclo