const observable = Rx.Observable.interval(1000).take(5);

​

// Observer1 を登録する

observable.subscribe(

  x => console.log(`Observer1 next: ${x}`),

  error => console.error(`Observer1 error: ${error}`),

  () => console.log('Observer1 complete')

);

​

setTimeout(() => {

  // Observer2 を登録する

  observable.subscribe(

    x => console.log(`Observer2 next: ${x}`),

    error => console.error(`Observer2 error: ${error}`),

    () => console.log('Observer2 complete')

  );

}, 2500);

// => "Observer1 next: 0" 

// => "Observer1 next: 1"

// このタイミングで Observer2 が登録され、通知が開始する（Observer1 とは異なる通知を受け取る）。

// => "Observer1 next: 2"

// => "Observer2 next: 0"

// => "Observer1 next: 3"

// => "Observer2 next: 1"

// => "Observer1 next: 4"

// => "Observer1 complete"

// => "Observer2 next: 2"

// => "Observer2 next: 3"

// => "Observer2 next: 4"

// => "Observer2 complete"