charsStream = Rx.Observable.from("Hello RX".split("")) timeStream = Rx.Observable.interval(1000); Rx.Observable.zip(charsStream, timeStream, (c,_) -> c) .subscribe( (c) -> $console.log(c))