rxintervaltakemap.js

#!/usr/bin/env node

const Rx = require( 'rxjs' ),
      s$ = Rx.Observable
  .interval( 100 )
  .take( 10 )
  .filter( function( v ) {
    if( v % 2 == 0 ) {
      return v;
    }
  })
  .map( v =>
    '' + v + ' ' + Date.now()
  )
/*
Alternatively you can replace the line below the comment if you'd like to separate the init and the execute of your observable with the following one:
;  s$.subscribe(
*/
  .subscribe( v => {
      console.log( v );
    }, err => {
      console.log( err );
    }, completed => {
      console.log( 'Ding! Ding! Ding!' );
    }
  )