with defer

manager.go

@@ -33,27 +33,34 @@ func NewManager() *Manager {
 type ComponentsAreReady struct {
 }
 
-func (m *Manager) RunNonBlocking(ctx context.Context) error {
+func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) error {
-	m.initLifetime()
+	go func() error {
-	err := m.init(ctx)
+		defer func(ctx context.Context) {
-	if err != nil {
+			err := m.shutdown(ctx)
-		return err
+			if err != nil {
-	}
+				panic(err)
+			}
+		}(ctx)
+		m.initLifetime()
+		err := m.init(ctx)
+		if err != nil {
+			return err
+		}
 
-	err = m.startBlocking(ctx)
+		err = m.startBlocking(ctx)
-	if err != nil {
+		if err != nil {
-		return err
+			return err
-	}
+		}
 
-	err = m.wait(ctx)
+		readyChan <- ComponentsAreReady{}
-	if err != nil {
-		return err
-	}
 
-	err = m.shutdown(ctx)
+		err = m.wait(ctx)
-	if err != nil {
+		if err != nil {
-		return err
+			return err
-	}
+		}
+
+		return nil
+	}()
 	return nil
 }