reactivex_player_observable.js

var authorizations =
    player
        .init()
        .map(() =>
            playAttemps
                .map(movieId =>
                    player.authorize(movieId)
                        .retry(3)
                        .takeUntil(cancels))
                .concatAll())
        .concatAll();

authorizations.forEach(
    license => player.play(license),
    error => showError()
);