Method SubscribeReloadEventFrom

di/factory.go:58–76

SubscribeReloadEventFrom subscribes to the reload events from dispatcher and then notifies the di factory to clear its cache and shutdown all connections gracefully.

(dispatcher contract.Dispatcher)

// SubscribeReloadEventFrom subscribes to the reload events from dispatcher and then notifies the di
// factory to clear its cache and shutdown all connections gracefully.
func (f *Factory) SubscribeReloadEventFrom(dispatcher contract.Dispatcher) {
	if dispatcher == nil {
		return
	}
	f.reloadOnce.Do(func() {
		dispatcher.Subscribe(events.Listen(events.OnReload, func(ctx context.Context, event interface{}) error {
			f.cache.Range(func(key, value interface{}) bool {
				defer f.cache.Delete(key)
				pair := value.(Pair)
				if pair.Closer == nil {
					return true
				}
				pair.Closer()
				return true
			})
			return nil
		}))
	})
}

// List lists created instance in the factory.
func (f *Factory) List() map[string]Pair {