(nc *nats.Conn, handlers handlers)
| 609 | } |
| 610 | |
| 611 | func unwrapConnectionEventCallbacks(nc *nats.Conn, handlers handlers) { |
| 612 | if nc.IsClosed() { |
| 613 | return |
| 614 | } |
| 615 | nc.SetClosedHandler(handlers.closed) |
| 616 | nc.SetErrorHandler(handlers.asyncErr) |
| 617 | } |
| 618 | |
| 619 | func (s *service) matchSubscriptionSubject(subj string) (*Endpoint, bool) { |
| 620 | s.m.Lock() |
no test coverage detected