with defer

manager.go

@@ -30,9 +30,37 @@ func NewManager() *Manager {
 	}
 }
 
-func (m *Manager) RunNonBlocking(ctx context.Context) error {
-	go m.Run(ctx)
+type ComponentsAreReady struct {
+}
 
+func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) error {
+	go func() error {
+		defer func(ctx context.Context) {
+			err := m.shutdown(ctx)
+			if err != nil {
+				panic(err)
+			}
+		}(ctx)
+		m.initLifetime()
+		err := m.init(ctx)
+		if err != nil {
+			return err
+		}
+
+		err = m.startBlocking(ctx)
+		if err != nil {
+			return err
+		}
+
+		readyChan <- ComponentsAreReady{}
+
+		err = m.wait(ctx)
+		if err != nil {
+			return err
+		}
+
+		return nil
+	}()
 	return nil
 }
 
@@ -98,6 +126,14 @@ func (m *Manager) start(ctx context.Context) error {
 	return nil
 }
 
+func (m *Manager) startBlocking(ctx context.Context) error {
+	for _, c := range m.components {
+		m.startComponent(ctx, c)
+	}
+
+	return nil
+}
+
 func (m *Manager) startComponent(ctx context.Context, component Component) {
 	defer func() {
 		err := recover()