const Observable = Rx.Observable;

const BehaviorSubject = Rx.BehaviorSubject;

const Subject = Rx.Subject;

​

var routes$ = new BehaviorSubject(['default']);

​

routes$.switchMap((arr) => {

    return Observable.interval(200)

        .take(arr.length)

        .map(i => arr[i])

        .timeInterval()

        .do(null, null, () => console.log('Complete'));

​

}).subscribe(value => {

    console.log(value);

});

​

routes$.next(['left', 'top', 'left']);

​

setTimeout(() => {

    routes$.next(['top', 'right', 'down']);

}, 1000);