Tutorial by Examples

const md = Rx.Observable.fromEvent(document, 'mousedown').map(true); // `md` will emit `true` whenever the mouse is pressed const mu = Rx.Observable.fromEvent(document, 'mouseup').map(false); // `mu` will emit `false` whenever the mouse is depressed

const source = Rx.Observable.range(1, 3) .map(x => x * x); const subscription = source.subscribe( x => console.log(`Next: ${x}`), err => console.log(`Error: ${err}`), () => console.log(`Completed`) ); // => Next: 1 // => Next: 4 // => Next: 9 // => Compl...

const source = Rx.Observable.range(1, 3) .map((x, idx, obs) => `Element ${x} was at position ${idx}`); const subscription = source.subscribe( x => console.log(`Next: ${x}`), err => console.log(`Error: ${err}`), () => console.log(`Completed`) ); // => Next: Element 1...