func (engine *DockerTaskEngine) handleDockerEvents(ctx context.Context) {
	for {
		select {
		case <-ctx.Done():
			return
		case event := <-engine.events:
			engine.handleDockerEvent(event)
		}
	}
}
func (engine *DockerTaskEngine) handleDockerEvents(ctx context.Context) {
	for {
		select {
		case <-ctx.Done():
			return
		case event := <-engine.events:
			engine.handleDockerEvent(event)
		}
	}
}
func ( engine * DockerTaskEngine ) handleDockerEvents ( ctx context . Context ) { for { select { case <- ctx . Done ( ) : return case event := <- engine . events : engine . handleDockerEvent ( event ) } } }
// handleDockerEvents must be called after openEventstream; it processes each
// event that it reads from the docker eventstream
handleDockerEvents must be called after openEventstream ; it processes each event that it reads from the docker eventstream