INNER CODE UNIT · Go

sub

resgateio/resgate · nats/nats.go:315

	sub := v.(*nats.Subscription)

	c.mu.Lock()
	rc, ok := c.mqReqs[sub]
	delete(c.mqReqs, sub)
	c.mu.Unlock()

	if !ok {
		return
	}

	if rc.t != nil {
		rc.t.Stop()
	}
	sub.Unsubscribe()

	c.Tracef("x=> (%s) Request timeout", inboxSubstr(sub.Subject))
	rc.f("", nil, mq.ErrRequestTimeout)

View source record →