function sample(){ var just = Rx.helpers.just; Rx.Observable.interval(1000) .take(5) .subscribe( function(s){ $("#memo").html(s); }, function(error){ console.log("error!"); }, function(){ console.log("finish!"); } ); }