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