With actual nonblocking one by one manager

builder.go

@@ -3,9 +3,9 @@ package curre
 import "context"
 
 type FunctionalComponent struct {
-	init  func(ctx context.Context) error
+	InitFunc  func(fc *FunctionalComponent, ctx context.Context) error
-	start func(ctx context.Context) error
+	StartFunc func(fc *FunctionalComponent, ctx context.Context) error
-	stop  func(ctx context.Context) error
+	StopFunc  func(fc *FunctionalComponent, ctx context.Context) error
 }
 
 func NewFunctionalComponent(
@@ -15,20 +15,20 @@ func NewFunctionalComponent(
 }
 
 func (fc *FunctionalComponent) Init(ctx context.Context) error {
-	if fc.init != nil {
+	if fc.InitFunc != nil {
-		return fc.init(ctx)
+		return fc.InitFunc(fc, ctx)
 	}
 	return nil
 }
 func (fc *FunctionalComponent) Start(ctx context.Context) error {
-	if fc.start != nil {
+	if fc.StartFunc != nil {
-		return fc.start(ctx)
+		return fc.StartFunc(fc, ctx)
 	}
 	return nil
 }
 func (fc *FunctionalComponent) Stop(ctx context.Context) error {
-	if fc.stop != nil {
+	if fc.StopFunc != nil {
-		return fc.stop(ctx)
+		return fc.StopFunc(fc, ctx)
 	}
 	return nil
 }

manager.go

@@ -30,9 +30,30 @@ func NewManager() *Manager {
 	}
 }
 
-func (m *Manager) RunNonBlocking(ctx context.Context) error {
+type ComponentsAreReady struct {
-	go m.Run(ctx)
+}
 
+func (m *Manager) RunNonBlocking(ctx context.Context) error {
+	m.initLifetime()
+	err := m.init(ctx)
+	if err != nil {
+		return err
+	}
+
+	err = m.startBlocking(ctx)
+	if err != nil {
+		return err
+	}
+
+	err = m.wait(ctx)
+	if err != nil {
+		return err
+	}
+
+	err = m.shutdown(ctx)
+	if err != nil {
+		return err
+	}
 	return nil
 }
 
@@ -98,6 +119,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()