Method Close

di/factory.go:90–106

Close closes every connection created by the factory. Connections are closed concurrently.

()

// Close closes every connection created by the factory. Connections are closed
// concurrently.
func (f *Factory) Close() {
	var wg sync.WaitGroup
	f.cache.Range(func(key, value interface{}) bool {
		defer f.cache.Delete(key)

		if value.(Pair).Closer == nil {
			return true
		}
		wg.Add(1)
		go func(value Pair) {
			value.Closer()
			wg.Done()
		}(value.(Pair))
		return true
	})
	wg.Wait()
}

// CloseConn closes a specific connection in the factory.
func (f *Factory) CloseConn(name string) {