Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
5f89d83094
|
|||
f9109382cb
|
17
manager.go
17
manager.go
@@ -33,7 +33,14 @@ 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 {
|
||||
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 {
|
||||
@@ -45,15 +52,15 @@ func (m *Manager) RunNonBlocking(ctx context.Context) error {
|
||||
return err
|
||||
}
|
||||
|
||||
readyChan <- ComponentsAreReady{}
|
||||
|
||||
err = m.wait(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
err = m.shutdown(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}()
|
||||
return nil
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user