non-blocking version of IndexUserVideo

index_user_video.go

func (service *IndexService) IndexUserVideo(userID, videoID string) error {
        var indexRequest IndexRequest
        var err error

        done := make(chan bool)
        u := make(chan *UserResponse)
        v := make(chan *VideoResponse)
        e := make(chan error)

        go func(){
                userResponse, err := service.GetUser(userID)
                if err != nil {
                        e <- err
                } else {
                        u <- userResponse
                }
        }()

        go func(){
                videoResponse, err := service.GetVideo(videoID)
                if err != nil {
                        e <- err
                }else{
                        v <- videoResponse
                }
        }()

        go func(){
                for {
                        select {
                        case response := <- u:
                                indexRequest.User = response.Data
                                done <- true
                        case response := <- v:
                                indexRequest.Video = response.Data
                                done <- true
                        case val := <- e:
                                err = val
                                done <- true
                        }
                }
        }()

        <- done
        if err != nil {
                return err
        }
        <- done

        err = service.PostIndex(indexRequest)
        return err
}