Method Subscribe

pkg/natsconn/natsconn.go:101–120

Subscribe registers for reconnection notifications. The returned channel receives a signal each time the NATS connection is re-established. The subscription is automatically removed when ctx is cancelled. Nil-receiver safe: returns a closed channel.

(ctx context.Context)

// The subscription is automatically removed when ctx is cancelled.
// Nil-receiver safe: returns a closed channel.
func (rc *ReloadableConnection) Subscribe(ctx context.Context) <-chan struct{} {
	if rc == nil {
		ch := make(chan struct{})
		close(ch)
		return ch
	}

	ch := make(chan struct{}, 1)

	rc.mu.Lock()
	rc.subscribers = append(rc.subscribers, ch)
	rc.mu.Unlock()

	go func() {
		<-ctx.Done()
		rc.unsubscribe(ch)
	}()

	return ch
}

func (rc *ReloadableConnection) unsubscribe(ch chan struct{}) {
	rc.mu.Lock()