const Observable = Rx.Observable;

const BehaviorSubject = Rx.BehaviorSubject;

const ReplaySubject = Rx.ReplaySubject;

​

const behavior = new BehaviorSubject(null);

const replay = new ReplaySubject(1);

​

behavior.skip(1).subscribe(v => console.log('BehaviorSubject:', v));

replay.subscribe(v => console.log('ReplaySubject:', v));

​

behavior.next(1);

behavior.next(2);

behavior.complete();

behavior.subscribe(v => console.log('Late B subscriber:', v));

​

​

replay.next(1);

replay.next(2);

replay.complete();

replay.subscribe(v => console.log('Late R subscriber:', v));

​