22-rxjs.md

Reactive Extentions (RxJS)

RxJS 6.x

Setup

• rxjs npm install rxjs
• rxjs-stream npm install rxjs-stream

Observable

Subscribe / Unsubscribe

const subscription = observable.subscribe(
  data => console.log('Next', data),
  error => console.error('Error', error),
  () => console.log('Complete')
);
subscription.unsubscribe();

Observer

observable.subscribe({
  next(data) {
    console.log('Next', data);
  },
  error(error) {
    console.error('Error', error);
  },
  complete() {
    console.log('Complete');
  },
});

Into observable

• From
  • Range
  • Array
  • Promise
• Subject
• Timer
• Interval

Combination operators

• tap
• filter
• map
• scan
• zip

NodeJS

• rxToStream
• streamToRx
• bindNodeCallback

Subjects

• Child-Subscriptions
• multicast
• refCount
• BehaviorSubject
• ReplaySubject
• AsyncSubject

Schedulers

• VirtualTimeScheduler
• TestScheduler

Resources / Links

• Learn Rx
• Rx Marbles
• Zen-Observable