Rx.Observable .interval(1000) .select( (x) -> "#{x}.Hello RX") .subscribe( (message) -> $console.log(message))