import { Observable } from "rxjs/Observable";
import "rxjs/add/observable/defer";
import "rxjs/add/observable/of";

const random = () => Math.floor(Math.random() * 10);
const source = Observable.defer(() => Observable.of(
  random(),
  random(),
  random()
));

const subject = new Rx.Subject<number>();

source.subscribe(
  value => console.log(`subscription 1: ${value}`),
  undefined,
  () => console.log("subscription 1: complete")
);
source.subscribe(
  value => console.log(`subscription 2: ${value}`),
  undefined,
  () => console.log("subscription 2: complete")
);
source.subscribe(subject);