Method PollJobToEventStream

actor/v7action/job.go:28–48

(jobURL ccv3.JobURL)

}

func (actor Actor) PollJobToEventStream(jobURL ccv3.JobURL) chan PollJobEvent {
	input := actor.CloudControllerClient.PollJobToEventStream(jobURL)
	if input == nil {
		return nil
	}

	output := make(chan PollJobEvent)

	go func() {
		for event := range input {
			output <- PollJobEvent{
				State:    JobState(event.State),
				Err:      event.Err,
				Warnings: Warnings(event.Warnings),
			}
		}
		close(output)
	}()

	return output
}