(r Runnable)
| 237 | } |
| 238 | |
| 239 | func (e *DockerEnvironment) registerStarted(r Runnable) error { |
| 240 | e.started = append(e.started, r) |
| 241 | |
| 242 | for _, l := range e.listeners { |
| 243 | if err := l.OnRunnableChange(e.started); err != nil { |
| 244 | return err |
| 245 | } |
| 246 | } |
| 247 | return nil |
| 248 | } |
| 249 | |
| 250 | func (e *DockerEnvironment) registerStopped(name string) error { |
| 251 | for i, r := range e.started { |